diff options
author | hor911 <hor911@ydb.tech> | 2022-09-30 18:03:21 +0300 |
---|---|---|
committer | hor911 <hor911@ydb.tech> | 2022-09-30 18:03:21 +0300 |
commit | 704c3e366e2dada4f6c33e7538ac1b0682c2de10 (patch) | |
tree | c4c26865e171dbc18e625892a01e81e0c0a1cdfe | |
parent | 0febcae4fc6ab53f99de2c988afa15ee195d0f20 (diff) | |
download | ydb-704c3e366e2dada4f6c33e7538ac1b0682c2de10.tar.gz |
Correct deriv sensors processing
-rw-r--r-- | ydb/library/yql/providers/dq/actors/task_controller.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/ydb/library/yql/providers/dq/actors/task_controller.cpp b/ydb/library/yql/providers/dq/actors/task_controller.cpp index 62a1c05cf55..6ccb29ee839 100644 --- a/ydb/library/yql/providers/dq/actors/task_controller.cpp +++ b/ydb/library/yql/providers/dq/actors/task_controller.cpp @@ -256,7 +256,8 @@ private: if (publicCounterName) { auto& counter = *ServiceCounters.PublicCounters->GetNamedCounter("name", publicCounterName, isDeriv); - if (isDeriv) { + if (name == "MultiHop_LateThrownEventsCount") { + // the only incremental sensor from TaskRunner counter += v.Count; } else { counter = v.Count; |