From e8452fc9476833d40576e73fe208f579d3c06655 Mon Sep 17 00:00:00 2001 From: obdev Date: Wed, 6 Jul 2022 17:34:10 +0800 Subject: [PATCH] fix issue 9263606 --- src/storage/memtable/ob_lock_wait_mgr.cpp | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/storage/memtable/ob_lock_wait_mgr.cpp b/src/storage/memtable/ob_lock_wait_mgr.cpp index 9e478f5bc7..3165e40d2c 100644 --- a/src/storage/memtable/ob_lock_wait_mgr.cpp +++ b/src/storage/memtable/ob_lock_wait_mgr.cpp @@ -296,12 +296,11 @@ ObLink* ObLockWaitMgr::check_timeout() iter->on_retry_lock(hash); TRANS_LOG(INFO, "current task should be waken up", K(*iter)); } else if (0 == iter->sessid_) { - // when lock wait in dag worker, session is not exist - need_check_session = false; + // do nothing, may be rpc plan, sessionid is not setted } else { // do nothing } - if (need_check_session) { + if (need_check_session && iter->sessid_ != 0) { // when lock wait in dag worker, session is not exist sql::ObSQLSessionInfo* session_info = NULL; int ret = OB_SUCCESS; int tmp_ret = OB_SUCCESS; -- GitLab