Skip to content

Commit 78556e0

Browse files
correct state checker (problem may happened in case scanner starting) (#14737)
1 parent 193db61 commit 78556e0

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

ydb/core/kqp/compute_actor/kqp_scan_fetcher_actor.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -376,7 +376,7 @@ void TKqpScanFetcherActor::HandleExecute(TEvents::TEvUndelivered::TPtr& ev) {
376376
auto state = InFlightShards.GetShardStateVerified(info->GetTabletId());
377377
AFL_WARN(NKikimrServices::KQP_COMPUTE)("event", "TEvents::TEvUndelivered")("from_tablet", info->GetTabletId())
378378
("state", state->State)("details", info->ToString())("node", SelfId().NodeId());
379-
AFL_ENSURE(state->State == EShardState::Running)("state", state->State);
379+
AFL_ENSURE(state->State == EShardState::Running || state->State == EShardState::Starting)("state", state->State);
380380
RetryDeliveryProblem(state);
381381
}
382382
return;

0 commit comments

Comments
 (0)