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

when DM interrupts qc, it is necessary to update_qc_error_code

Browse Source
This commit is contained in:
obdev
2023-06-16 02:18:19 +00:00
committed by ob-robot
parent bd3a3b98fd
commit bb6a7c5b38
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/sql/engine/px/ob_px_coord_op.cpp
View File

@ -842,6 +842,10 @@ int ObPxCoordOp::check_all_sqc(ObIArray<ObDfo *> &active_dfos,
all_dfo_terminate = false; all_dfo_terminate = false;
break; break;
} else if (sqc->is_server_not_alive() || sqc->is_interrupt_by_dm()) { } else if (sqc->is_server_not_alive() || sqc->is_interrupt_by_dm()) {
if (sqc->is_interrupt_by_dm()) {
ObRpcResultCode err_msg;
ObPxErrorUtil::update_qc_error_code(coord_info_.first_error_code_, OB_RPC_CONNECT_ERROR, err_msg);
}
sqc->set_server_not_alive(false); sqc->set_server_not_alive(false);
sqc->set_interrupt_by_dm(false); sqc->set_interrupt_by_dm(false);
const DASTabletLocIArray &access_locations = sqc->get_access_table_locations(); const DASTabletLocIArray &access_locations = sqc->get_access_table_locations();