aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorhor911 <hor911@ydb.tech>2023-04-04 22:50:26 +0300
committerhor911 <hor911@ydb.tech>2023-04-04 22:50:26 +0300
commitd4d3f75e15c428924032f43a71439f301b319edb (patch)
tree6b1a507221a5206443da4a6c450c8278968f3ae8
parentb27c25b97b8cbe974d5f4898a024ed6f512265d5 (diff)
downloadydb-d4d3f75e15c428924032f43a71439f301b319edb.tar.gz
Publish Source CPU usage in sync CA
-rw-r--r--ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h
index 0b56f2b15b2..bc9be1d1403 100644
--- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h
+++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h
@@ -1952,8 +1952,8 @@ public:
// More accurate cpu time counter:
if (TDerived::HasAsyncTaskRunner) {
protoTask->SetCpuTimeUs(BasicStats->CpuTime.MicroSeconds() + taskStats->ComputeCpuTime.MicroSeconds() + taskStats->BuildCpuTime.MicroSeconds());
- protoTask->SetSourceCpuTimeUs(SourceCpuTime.MicroSeconds());
}
+ protoTask->SetSourceCpuTimeUs(SourceCpuTime.MicroSeconds());
for (auto& [outputIndex, sinkInfo] : SinksMap) {