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

[CP] fix px retry 4377

Browse Source
This commit is contained in:
sdc
2024-01-04 07:43:08 +00:00
committed by ob-robot
parent 4edffe3c86
commit d9accd212d
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/sql/engine/px/ob_dfo_scheduler.cpp
View File

@ -1217,17 +1217,13 @@ int ObParallelDfoScheduler::dispatch_sqc(ObExecContext &exec_ctx,
LOG_WARN("[DM] fail to push back dtl channels", K(push_ret), K(sqc.get_sqc_addr()), LOG_WARN("[DM] fail to push back dtl channels", K(push_ret), K(sqc.get_sqc_addr()),
K(dfo.get_px_detectable_ids().sqc_detectable_id_)); K(dfo.get_px_detectable_ids().sqc_detectable_id_));
} }
} else if (!cb->is_processed()) { } else {
// if init_sqc_msg is not processed and the msg may be sent successfully, set server not alive. // if init_sqc_msg is not processed and the msg may be sent successfully, set server not alive.
// then when qc waiting_all_dfo_exit, it will push sqc.access_table_locations into trans_result, // then when qc waiting_all_dfo_exit, it will push sqc.access_table_locations into trans_result,
// and the query can be retried. // and the query can be retried.
bool msg_not_send_out = (cb->get_error() == EASY_TIMEOUT_NOT_SENT_OUT
|| cb->get_error() == EASY_DISCONNECT_NOT_SENT_OUT);
if (!msg_not_send_out) {
sqc.set_server_not_alive(true); sqc.set_server_not_alive(true);
} }
} }
}
}; };
if (OB_FAIL(ret)) { if (OB_FAIL(ret)) {
} else if (OB_FAIL(proxy.launch_all_rpc_request())) { } else if (OB_FAIL(proxy.launch_all_rpc_request())) {