fixed unclosed result channel proxies

Зачистки ResultChannelProxies не хватало в kqp_data_executer.cpp, ссылка:
https://a.yandex-team.ru/arcadia/ydb/core/kqp/executer_actor/kqp_data_executer.cpp?rev=rXXXXXX#L2312-2327

2 files changed, 9 insertions, 9 deletions

diff --git a/ydb/core/kqp/executer_actor/kqp_executer_impl.h b/ydb/core/kqp/executer_actor/kqp_executer_impl.h
index 734315dd1f..0df3adb488 100644
--- a/ydb/core/kqp/executer_actor/kqp_executer_impl.h
+++ b/ydb/core/kqp/executer_actor/kqp_executer_impl.h
@@ -1173,6 +1173,15 @@ protected:
 
 protected:
     void PassAway() override {
+        for (auto channelPair: ResultChannelProxies) {
+            LOG_D("terminate result channel " << channelPair.first << " proxy at " << channelPair.second->SelfId());
+
+            TAutoPtr<IEventHandle> ev = new IEventHandle(
+                channelPair.second->SelfId(), SelfId(), new TEvents::TEvPoison
+            );
+            channelPair.second->Receive(ev);
+        }
+
         LOG_D("terminate execution.");
         if (KqpShardsResolverId) {
             this->Send(KqpShardsResolverId, new TEvents::TEvPoison);
diff --git a/ydb/core/kqp/executer_actor/kqp_scan_executer.cpp b/ydb/core/kqp/executer_actor/kqp_scan_executer.cpp
index 8179d8162c..95b8bd8d70 100644
--- a/ydb/core/kqp/executer_actor/kqp_scan_executer.cpp
+++ b/ydb/core/kqp/executer_actor/kqp_scan_executer.cpp
@@ -687,15 +687,6 @@ private:
     }
 
     void PassAway() override {
-        for (auto channelPair: GetResultChannelProxies()) {
-            LOG_D("terminate result channel " << channelPair.first << " proxy at " << channelPair.second->SelfId());
-
-            TAutoPtr<IEventHandle> ev = new IEventHandle(
-                channelPair.second->SelfId(), SelfId(), new TEvents::TEvPoison
-            );
-            channelPair.second->Receive(ev);
-        }
-
         auto totalTime = TInstant::Now() - StartTime;
         Counters->Counters->ScanTxTotalTimeHistogram->Collect(totalTime.MilliSeconds());