Fix StageDurationUs (#984)

Hor911 · web-flow · commit 3fce1e1d6a5d · 2024-01-15T12:55:06.000+03:00
diff --git 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);
         }

Original file line number	Diff line number	Diff line change
`@@ -330,7 +330,7 @@ bool CollectProfileStats(Ydb::Table::QueryStatsCollection::Mode statsMode) {`
`330`	`330`	`void TQueryExecutionStats::FillStageDurationUs(NYql::NDqProto::TDqStageStats& stats) {`
`331`	`331`	`if (stats.HasStartTimeMs() && stats.HasFinishTimeMs()) {`
`332`	`332`	`auto startTimeMs = stats.GetStartTimeMs().GetMin();`
`333`		`- auto finishTimeMs = stats.GetFinishTimeMs().GetMin();`
	`333`	`+ auto finishTimeMs = stats.GetFinishTimeMs().GetMax();`
`334`	`334`	`if (startTimeMs && finishTimeMs > startTimeMs) {`
`335`	`335`	`stats.SetStageDurationUs((finishTimeMs - startTimeMs) * 1'000);`
`336`	`336`	`}`