aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAleksei Borzenkov <snaury@ydb.tech>2024-12-24 14:45:38 +0300
committerGitHub <noreply@github.com>2024-12-24 14:45:38 +0300
commit3b45c906bef6671a321a223bf3c6e3aa117fc6df (patch)
tree6e98c8481fd5552fe25c2dfe1199eab352f0b583
parent8b4e2e39c45ef488856eadd855620329dc679f51 (diff)
downloadydb-3b45c906bef6671a321a223bf3c6e3aa117fc6df.tar.gz
Fix a reversed MissingConfig counter in coordinator (#12907)
-rw-r--r--ydb/core/tx/coordinator/coordinator__configure.cpp2
-rw-r--r--ydb/core/tx/coordinator/coordinator__init.cpp2
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);