From b2d10bfb1522c4a3e088dd9d0ee1d3359a192d80 Mon Sep 17 00:00:00 2001 From: Aleksandr Khoroshilov Date: Thu, 20 Mar 2025 18:14:22 +0300 Subject: [PATCH] Correct in progress stats level --- ydb/core/kqp/executer_actor/kqp_executer_impl.h | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/ydb/core/kqp/executer_actor/kqp_executer_impl.h b/ydb/core/kqp/executer_actor/kqp_executer_impl.h index 63a25cc1bdf0..f11bc282b7b9 100644 --- a/ydb/core/kqp/executer_actor/kqp_executer_impl.h +++ b/ydb/core/kqp/executer_actor/kqp_executer_impl.h @@ -430,12 +430,14 @@ class TKqpExecuterBase : public TActor { auto now = TInstant::Now(); if (LastProgressStats + Request.ProgressStatsPeriod <= now) { auto progress = MakeHolder(); - auto& execStats = *progress->Record.MutableQueryStats()->AddExecutions(); - Stats->ExportExecStats(execStats); - for (ui32 txId = 0; txId < Request.Transactions.size(); ++txId) { - const auto& tx = Request.Transactions[txId].Body; - auto planWithStats = AddExecStatsToTxPlan(tx->GetPlan(), execStats); - execStats.AddTxPlansWithStats(planWithStats); + if (CollectFullStats(Request.StatsMode)) { + auto& execStats = *progress->Record.MutableQueryStats()->AddExecutions(); + Stats->ExportExecStats(execStats); + for (ui32 txId = 0; txId < Request.Transactions.size(); ++txId) { + const auto& tx = Request.Transactions[txId].Body; + auto planWithStats = AddExecStatsToTxPlan(tx->GetPlan(), execStats); + execStats.AddTxPlansWithStats(planWithStats); + } } this->Send(Target, progress.Release()); LastProgressStats = now;