aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorgvit <gvit@ydb.tech>2023-03-16 11:29:27 +0300
committergvit <gvit@ydb.tech>2023-03-16 11:29:27 +0300
commit7c82bf16a913cb7137888afee6dbb649abdd8ee2 (patch)
tree24f12bdb1a7fb795605c1574ec664db3b2698b86
parenta4f8fe5dd442463491637d97990f8d4febf6048a (diff)
downloadydb-7c82bf16a913cb7137888afee6dbb649abdd8ee2.tar.gz
ignore outdated event from unknown executer
-rw-r--r--ydb/core/kqp/session_actor/kqp_session_actor.cpp5
1 files changed, 5 insertions, 0 deletions
diff --git a/ydb/core/kqp/session_actor/kqp_session_actor.cpp b/ydb/core/kqp/session_actor/kqp_session_actor.cpp
index ef0721cc1ff..8ef17235862 100644
--- a/ydb/core/kqp/session_actor/kqp_session_actor.cpp
+++ b/ydb/core/kqp/session_actor/kqp_session_actor.cpp
@@ -1310,6 +1310,11 @@ public:
}
void HandleExecute(TEvKqpExecuter::TEvTxResponse::TPtr& ev) {
+ // outdated response from dead executer.
+ // it this case we should just ignore the event.
+ if (ExecuterId != ev->Sender)
+ return;
+
TTimerGuard timer(this);
ProcessExecuterResult(ev->Get());
}