Skip to content

Commit 02234c6

Browse files
authored
verify tasksSize == actorIds.size() has been changed to internal erro… (#11437)
1 parent bb0e22c commit 02234c6

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

ydb/core/fq/libs/checkpointing/checkpoint_coordinator.cpp

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,10 @@ void TCheckpointCoordinator::Handle(NYql::NDqs::TEvReadyState::TPtr& ev) {
7373

7474
int tasksSize = GetTasksSize();
7575
const auto& actorIds = ev->Get()->Record.GetActorId();
76-
Y_ABORT_UNLESS(tasksSize == actorIds.size(), "tasksSize %d, actorIds size %d, graph id %s", tasksSize, int(actorIds.size()), CoordinatorId.GraphId.c_str());
76+
if (tasksSize != actorIds.size()) {
77+
OnInternalError(TStringBuilder() << "tasksSize != actorIds.size(), tasksSize " << tasksSize << ", actorIds size " << actorIds.size() << ", graph id " << CoordinatorId.GraphId);
78+
return;
79+
}
7780

7881
for (int i = 0; i < tasksSize; ++i) {
7982
const auto& task = GetTask(i);

0 commit comments

Comments
 (0)