diff options
| author | Alexey Ozeritskiy <aozeritsky@ydb.tech> | 2023-12-19 17:44:38 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-12-19 17:44:38 +0100 |
| commit | 4ff35feca60dc6f4c32d4ec4eee74b47f0332b7d (patch) | |
| tree | 543060ba7a4c0311f682b247d007a2b17e17d5c1 | |
| parent | 55d122badd479a8e15c18fe91cf146d92158cdfc (diff) | |
| download | ydb-4ff35feca60dc6f4c32d4ec4eee74b47f0332b7d.tar.gz | |
Flush queue and end Final message immidiately on full result writer error (#582)
| -rw-r--r-- | ydb/library/yql/providers/dq/actors/result_actor_base.h | 2 |
1 files changed, 2 insertions, 0 deletions
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 bdf0ca35dc6..f92a2950444 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()); } |