diff options
author | whcrc <whcrc@yandex-team.ru> | 2022-05-23 18:01:13 +0300 |
---|---|---|
committer | whcrc <whcrc@yandex-team.ru> | 2022-05-23 18:01:13 +0300 |
commit | 4e4cc5b19846b18c4d2a7ec22cf9c1b060058d84 (patch) | |
tree | 2d20a6d8308a93f7b580050c7053fb799413c191 | |
parent | 04600e854650ea1168cb5b27c108662b9be56478 (diff) | |
download | ydb-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.cpp | 2 |
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) { |