aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorwhcrc <whcrc@yandex-team.ru>2022-05-23 18:01:13 +0300
committerwhcrc <whcrc@yandex-team.ru>2022-05-23 18:01:13 +0300
commit4e4cc5b19846b18c4d2a7ec22cf9c1b060058d84 (patch)
tree2d20a6d8308a93f7b580050c7053fb799413c191
parent04600e854650ea1168cb5b27c108662b9be56478 (diff)
downloadydb-4e4cc5b19846b18c4d2a7ec22cf9c1b060058d84.tar.gz
YQL-14521: fix bug in ResultAggregator leading to unexpected events on shutdown
ref:15248a813d282792b4a17223f58e3453b09cbfda
-rw-r--r--ydb/library/yql/providers/dq/actors/executer_actor.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/library/yql/providers/dq/actors/executer_actor.cpp b/ydb/library/yql/providers/dq/actors/executer_actor.cpp
index 420722b0f2..7293afdbac 100644
--- a/ydb/library/yql/providers/dq/actors/executer_actor.cpp
+++ b/ydb/library/yql/providers/dq/actors/executer_actor.cpp
@@ -389,7 +389,7 @@ private:
auto readyState1 = res->Record;
auto readyState2 = res->Record;
Send(ControlId, res.Release());
- if (ResultId != SelfId()) {
+ if (ResultId != SelfId() && ResultId != ControlId) {
Send(ResultId, new TEvReadyState(std::move(readyState1)));
}
if (CheckPointCoordinatorId) {