Skip to content

Commit b5b53d0

Browse files
committed
Fixed compute actor finalizing in case of node disconnect
1 parent 9c8c951 commit b5b53d0

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

ydb/core/kqp/executer_actor/kqp_planner.cpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -616,6 +616,9 @@ void TKqpPlanner::TaskNotStarted(ui64 taskId) {
616616
YQL_ENSURE(!task.ComputeActorId);
617617
YQL_ENSURE(!task.Meta.Completed);
618618

619+
// Mark as completed, because node disconnect may be temporary, and CA will send TEvDqCompute::TEvState while shutting down
620+
task.Meta.Completed = true;
621+
619622
PendingComputeTasks.erase(taskId);
620623
}
621624

0 commit comments

Comments
 (0)