Skip to content

Commit 9185b23

Browse files
committed
Fix bug
1 parent d5afc6b commit 9185b23

File tree

1 file changed

+7
-8
lines changed

1 file changed

+7
-8
lines changed

ydb/core/kqp/executer_actor/kqp_executer_impl.h

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -411,11 +411,11 @@ class TKqpExecuterBase : public TActorBootstrapped<TDerived> {
411411
YQL_ENSURE(Planner);
412412
bool ack = Planner->AcknowledgeCA(taskId, computeActor, &state);
413413

414-
// Don't finalize stats twice.
415-
if (Planner->CompletedCA(taskId, computeActor)) {
416-
switch (state.GetState()) {
417-
case NYql::NDqProto::COMPUTE_STATE_FAILURE:
418-
case NYql::NDqProto::COMPUTE_STATE_FINISHED: {
414+
switch (state.GetState()) {
415+
case NYql::NDqProto::COMPUTE_STATE_FAILURE:
416+
case NYql::NDqProto::COMPUTE_STATE_FINISHED:
417+
// Don't finalize stats twice.
418+
if (Planner->CompletedCA(taskId, computeActor)) {
419419
ExtraData[computeActor].Swap(state.MutableExtraData());
420420

421421
if (Stats) {
@@ -429,9 +429,8 @@ class TKqpExecuterBase : public TActorBootstrapped<TDerived> {
429429
LastTaskId = taskId;
430430
LastComputeActorId = computeActor.ToString();
431431
}
432-
default:
433-
; // ignore all other states.
434-
}
432+
default:
433+
; // ignore all other states.
435434
}
436435

437436
return ack;

0 commit comments

Comments
 (0)