提交 e8452fc9 编写于 作者: O obdev 提交者: wangzelin.wzl

fix issue 9263606

上级 924deae1
...@@ -296,12 +296,11 @@ ObLink* ObLockWaitMgr::check_timeout() ...@@ -296,12 +296,11 @@ ObLink* ObLockWaitMgr::check_timeout()
iter->on_retry_lock(hash); iter->on_retry_lock(hash);
TRANS_LOG(INFO, "current task should be waken up", K(*iter)); TRANS_LOG(INFO, "current task should be waken up", K(*iter));
} else if (0 == iter->sessid_) { } else if (0 == iter->sessid_) {
// when lock wait in dag worker, session is not exist // do nothing, may be rpc plan, sessionid is not setted
need_check_session = false;
} else { } else {
// do nothing // 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; sql::ObSQLSessionInfo* session_info = NULL;
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
int tmp_ret = OB_SUCCESS; int tmp_ret = OB_SUCCESS;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册