Flush queue and end Final message immidiately on full result writer error (#582)

resetius · web-flow · commit 4ff35feca60d · 2023-12-19T17:44:38.000+01:00
diff --git 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());
             }

Original file line number	Diff line number	Diff line change
`@@ -212,6 +212,8 @@ namespace NYql::NDqs::NExecutionHelpers {`
`212`	`212`	`if (ev->Get()->Record.IssuesSize() == 0) { // weird way used by writer to acknowledge it's death`
`213`	`213`	`DoFinish();`
`214`	`214`	`} else {`
	`215`	`+ WaitingAckFromFRW = false;`
	`216`	`+ WriteQueue.clear();`
`215`	`217`	`Y_ABORT_UNLESS(ev->Get()->Record.GetStatusCode() != NYql::NDqProto::StatusIds::SUCCESS);`
`216`	`218`	`TBase::Send(ExecuterID, ev->Release().Release());`
`217`	`219`	`}`