diff --git a/ydb/core/kqp/executer_actor/kqp_executer_stats.cpp b/ydb/core/kqp/executer_actor/kqp_executer_stats.cpp index 6b8b194b27d0..34633516825a 100644 --- a/ydb/core/kqp/executer_actor/kqp_executer_stats.cpp +++ b/ydb/core/kqp/executer_actor/kqp_executer_stats.cpp @@ -330,7 +330,7 @@ bool CollectProfileStats(Ydb::Table::QueryStatsCollection::Mode statsMode) { void TQueryExecutionStats::FillStageDurationUs(NYql::NDqProto::TDqStageStats& stats) { if (stats.HasStartTimeMs() && stats.HasFinishTimeMs()) { auto startTimeMs = stats.GetStartTimeMs().GetMin(); - auto finishTimeMs = stats.GetFinishTimeMs().GetMin(); + auto finishTimeMs = stats.GetFinishTimeMs().GetMax(); if (startTimeMs && finishTimeMs > startTimeMs) { stats.SetStageDurationUs((finishTimeMs - startTimeMs) * 1'000); }