YDB Import 502

ydb-platform · Dec 20, 2023 · 1cf5622 · 1cf5622
1 parent 4f47a6c
commit 1cf5622
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/contrib/ydb/library/yql/providers/dq/actors/result_actor_base.h b/contrib/ydb/library/yql/providers/dq/actors/result_actor_base.h
@@ -212,6 +212,8 @@ namespace NYql::NDqs::NExecutionHelpers {
             if (ev->Get()->Record.IssuesSize() == 0) {  // weird way used by writer to acknowledge it's death
                 DoFinish();
             } else {
+                WaitingAckFromFRW = false;
+                WriteQueue.clear();
                 Y_ABORT_UNLESS(ev->Get()->Record.GetStatusCode() != NYql::NDqProto::StatusIds::SUCCESS);
                 TBase::Send(ExecuterID, ev->Release().Release());
             }