diff options
author | gvit <gvit@ydb.tech> | 2023-03-16 11:29:27 +0300 |
---|---|---|
committer | gvit <gvit@ydb.tech> | 2023-03-16 11:29:27 +0300 |
commit | 7c82bf16a913cb7137888afee6dbb649abdd8ee2 (patch) | |
tree | 24f12bdb1a7fb795605c1574ec664db3b2698b86 | |
parent | a4f8fe5dd442463491637d97990f8d4febf6048a (diff) | |
download | ydb-7c82bf16a913cb7137888afee6dbb649abdd8ee2.tar.gz |
ignore outdated event from unknown executer
-rw-r--r-- | ydb/core/kqp/session_actor/kqp_session_actor.cpp | 5 |
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()); } |