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

[CP] [to #52558204]local retry not close ps stmt

Browse Source
This commit is contained in:
LiuYoung00 2023-10-12 07:47:54 +00:00 committed by ob-robot
parent 8f51ca5b93
commit dec121a850
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -573,9 +573,9 @@ int ObMPStmtPrexecute::execute_response(ObSQLSessionInfo &session,
if (OB_NOT_NULL(cursor) && OB_FAIL(session.close_cursor(cursor->get_id()))) {
LOG_WARN("close cursor failed.", K(ret), K(stmt_id_));
}
// first time the stmt_id do not response to the client
// Whether the cursor close is successful or not, it is required
if (first_time_ && OB_FAIL(session.close_ps_stmt(stmt_id_))) {
if (OB_FAIL(clean_ps_stmt(session,
RETRY_TYPE_LOCAL == retry_ctrl.get_retry_type(),
ctx.multi_stmt_item_.is_batched_multi_stmt()))) {
LOG_WARN("close cursor failed.", K(ret), K(stmt_id_));
}
ret = tmp_ret;