diff options
author | maksim-kita <maksim-kita@yandex-team.com> | 2023-11-07 14:57:41 +0300 |
---|---|---|
committer | maksim-kita <maksim-kita@yandex-team.com> | 2023-11-07 15:59:25 +0300 |
commit | 69078ba0ecd4a17b6871cc1ffea02b6c06e3e62c (patch) | |
tree | d836120f33dce63ee9f2a514e2daf44a6215f08c | |
parent | aadba0438cea385184a33bed33591bb909c72975 (diff) | |
download | ydb-69078ba0ecd4a17b6871cc1ffea02b6c06e3e62c.tar.gz |
KQPCompileComputationPatternService CompileComputationPatternsQueueSize sensor fix
-rw-r--r-- | ydb/core/kqp/compile_service/kqp_compile_computation_pattern_service.cpp | 4 |
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); } |