diff options
| author | Aleksei Borzenkov <snaury@ydb.tech> | 2024-12-24 14:45:38 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-12-24 14:45:38 +0300 |
| commit | 3b45c906bef6671a321a223bf3c6e3aa117fc6df (patch) | |
| tree | 6e98c8481fd5552fe25c2dfe1199eab352f0b583 | |
| parent | 8b4e2e39c45ef488856eadd855620329dc679f51 (diff) | |
| download | ydb-3b45c906bef6671a321a223bf3c6e3aa117fc6df.tar.gz | |
Fix a reversed MissingConfig counter in coordinator (#12907)
| -rw-r--r-- | ydb/core/tx/coordinator/coordinator__configure.cpp | 2 | ||||
| -rw-r--r-- | ydb/core/tx/coordinator/coordinator__init.cpp | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/ydb/core/tx/coordinator/coordinator__configure.cpp b/ydb/core/tx/coordinator/coordinator__configure.cpp index 67215a13b0..6c77d5a5af 100644 --- a/ydb/core/tx/coordinator/coordinator__configure.cpp +++ b/ydb/core/tx/coordinator/coordinator__configure.cpp @@ -123,7 +123,7 @@ struct TTxCoordinator::TTxConfigure : public TTransactionBase<TTxCoordinator> { if (ConfigurationApplied) { Self->Execute(Self->CreateTxInit(), ctx); } else { - Self->SetCounter(COUNTER_MISSING_CONFIG, Self->Config.HaveProcessingParams ? 1 : 0); + Self->SetCounter(COUNTER_MISSING_CONFIG, Self->Config.HaveProcessingParams ? 0 : 1); if (Self->Config.HaveProcessingParams) { Self->SubscribeToSiblings(); } diff --git a/ydb/core/tx/coordinator/coordinator__init.cpp b/ydb/core/tx/coordinator/coordinator__init.cpp index 35cc40c3a7..79c9c6b06d 100644 --- a/ydb/core/tx/coordinator/coordinator__init.cpp +++ b/ydb/core/tx/coordinator/coordinator__init.cpp @@ -124,7 +124,7 @@ struct TTxCoordinator::TTxInit : public TTransactionBase<TTxCoordinator> { Self->Config.Resolution = PlanResolution; Self->Config.ReducedResolution = ReducedResolution; Self->Config.HaveProcessingParams = HaveProcessingParams; - Self->SetCounter(COUNTER_MISSING_CONFIG, HaveProcessingParams ? 1 : 0); + Self->SetCounter(COUNTER_MISSING_CONFIG, HaveProcessingParams ? 0 : 1); if (LastBlockedActor && LastPlanned < LastBlockedStep) { Self->RestoreState(LastBlockedActor, LastBlockedStep); |