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

[CP] fix error report when handle trans result for remote execute sql

Browse Source
This commit is contained in:
chinaxing
2023-10-16 06:39:18 +00:00
committed by ob-robot
parent 83eed2863c
commit 7b9b5aa5a1
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/sql/executor/ob_remote_task_executor.cpp
View File

@ -100,13 +100,16 @@ int ObRemoteTaskExecutor::execute(ObExecContext &query_ctx, ObJob *job, ObTaskIn
} }
} }
// handle tx relative info if plan involved in transaction // handle tx relative info if plan involved in transaction
const ObPhysicalPlan *plan = plan_ctx->get_phy_plan();
if (plan && plan->is_need_trans()) {
int tmp_ret = handle_tx_after_rpc(handler->get_result(), int tmp_ret = handle_tx_after_rpc(handler->get_result(),
session, session,
has_sent_task, has_sent_task,
has_transfer_err, has_transfer_err,
plan_ctx->get_phy_plan(), plan,
query_ctx); query_ctx);
ret = COVER_SUCC(tmp_ret); ret = COVER_SUCC(tmp_ret);
}
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
ObExecFeedbackInfo &fb_info = handler->get_result()->get_feedback_info(); ObExecFeedbackInfo &fb_info = handler->get_result()->get_feedback_info();