verify tasksSize == actorIds.size() has been changed to internal error (

#11434)
ydb-platform · Nov 9, 2024 · 13fb53d · 13fb53d
1 parent 302fd2e
commit 13fb53d
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/ydb/core/fq/libs/checkpointing/checkpoint_coordinator.cpp b/ydb/core/fq/libs/checkpointing/checkpoint_coordinator.cpp
@@ -73,7 +73,10 @@ void TCheckpointCoordinator::Handle(NYql::NDqs::TEvReadyState::TPtr& ev) {
 
     int tasksSize = GetTasksSize();
     const auto& actorIds = ev->Get()->Record.GetActorId();
-    Y_ABORT_UNLESS(tasksSize == actorIds.size(), "tasksSize %d, actorIds size %d, graph id %s", tasksSize, int(actorIds.size()), CoordinatorId.GraphId.c_str());
+    if (tasksSize != actorIds.size()) {
+        OnInternalError(TStringBuilder() << "tasksSize != actorIds.size(),  tasksSize " << tasksSize << ", actorIds size " << actorIds.size() <<  ", graph id " << CoordinatorId.GraphId);
+        return;
+    }
 
     for (int i = 0; i < tasksSize; ++i) {
         const auto& task = GetTask(i);