From 4ff35feca60dc6f4c32d4ec4eee74b47f0332b7d Mon Sep 17 00:00:00 2001
From: Alexey Ozeritskiy <aozeritsky@ydb.tech>
Date: Tue, 19 Dec 2023 17:44:38 +0100
Subject: [PATCH] Flush queue and end Final message immidiately on full result
 writer error (#582)

---
 ydb/library/yql/providers/dq/actors/result_actor_base.h | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/ydb/library/yql/providers/dq/actors/result_actor_base.h b/ydb/library/yql/providers/dq/actors/result_actor_base.h
index bdf0ca35dc67..f92a2950444d 100644
--- a/ydb/library/yql/providers/dq/actors/result_actor_base.h
+++ b/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());
             }