hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CP] [to #54326346] before process set session in retry need consider the original state

Browse Source
This commit is contained in:
LiuYoung00
2024-01-10 12:47:20 +00:00
committed by ob-robot
parent 07a7b9758a
commit 74cdeab79a
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/observer/mysql/obmp_stmt_prexecute.cpp
View File

@ -254,9 +254,11 @@ int ObMPStmtPrexecute::before_process()
K(ret), K(cli_ret), K(get_retry_ctrl().need_retry()), K(sql_)); K(ret), K(cli_ret), K(get_retry_ctrl().need_retry()), K(sql_));
ret = cli_ret; ret = cli_ret;
} }
if (OB_FAIL(ret)) {
session->set_session_in_retry(retry_ctrl_.need_retry()); session->set_session_in_retry(retry_ctrl_.need_retry());
} }
} }
}
} while (RETRY_TYPE_LOCAL == retry_ctrl_.get_retry_type()); } while (RETRY_TYPE_LOCAL == retry_ctrl_.get_retry_type());
if (OB_SUCC(ret) && retry_ctrl_.get_retry_times() > 0) { if (OB_SUCC(ret) && retry_ctrl_.get_retry_times() > 0) {
LOG_TRACE("sql retry succeed", K(ret), LOG_TRACE("sql retry succeed", K(ret),