aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authormaksim-kita <maksim-kita@yandex-team.com>2023-11-07 14:57:41 +0300
committermaksim-kita <maksim-kita@yandex-team.com>2023-11-07 15:59:25 +0300
commit69078ba0ecd4a17b6871cc1ffea02b6c06e3e62c (patch)
treed836120f33dce63ee9f2a514e2daf44a6215f08c
parentaadba0438cea385184a33bed33591bb909c72975 (diff)
downloadydb-69078ba0ecd4a17b6871cc1ffea02b6c06e3e62c.tar.gz
KQPCompileComputationPatternService CompileComputationPatternsQueueSize sensor fix
-rw-r--r--ydb/core/kqp/compile_service/kqp_compile_computation_pattern_service.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/core/kqp/compile_service/kqp_compile_computation_pattern_service.cpp b/ydb/core/kqp/compile_service/kqp_compile_computation_pattern_service.cpp
index 2cec69c92c..e7a6803e61 100644
--- a/ydb/core/kqp/compile_service/kqp_compile_computation_pattern_service.cpp
+++ b/ydb/core/kqp/compile_service/kqp_compile_computation_pattern_service.cpp
@@ -69,12 +69,12 @@ private:
compilationIntervalMs -= static_cast<i64>(timer.Get().MilliSeconds());
}
+ Counters->CompileComputationPatternsQueueSize->Set(PatternsToCompile.size() - PatternToCompileIndex);
+
if (PatternToCompileIndex == patternsToCompileSize) {
PatternsToCompile.clear();
}
- Counters->CompileComputationPatternsQueueSize->Set(PatternsToCompile.size());
-
ScheduleWakeup(ctx);
}