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

Fix the hang with select with virtual table

Browse Source
This commit is contained in:
qianchanger
2022-11-04 10:10:23 +00:00
committed by wangzelin.wzl
parent b096903542
commit 142257dd28
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -516,7 +516,11 @@ int ObSerialDfoScheduler::dispatch_sqcs(ObExecContext &exec_ctx,
ret = OB_RPC_CONNECT_ERROR; ret = OB_RPC_CONNECT_ERROR;
LOG_WARN("peer no in communication, maybe crashed", K(ret), K(sqc), K(cluster_id), LOG_WARN("peer no in communication, maybe crashed", K(ret), K(sqc), K(cluster_id),
K(session->get_process_query_time())); K(session->get_process_query_time()));
} else {
LOG_WARN("ignore the black server list with virtual table", K(addr), K(ret));
} }
}
if (OB_FAIL(ret)) {
} else { } else {
SMART_VAR(ObPxRpcInitSqcArgs, args) { SMART_VAR(ObPxRpcInitSqcArgs, args) {
int64_t timeout_us = phy_plan_ctx->get_timeout_timestamp() - ObTimeUtility::current_time(); int64_t timeout_us = phy_plan_ctx->get_timeout_timestamp() - ObTimeUtility::current_time();
@ -1235,7 +1239,11 @@ int ObParallelDfoScheduler::fast_dispatch_sqc(ObExecContext &exec_ctx,
ret = OB_RPC_CONNECT_ERROR; ret = OB_RPC_CONNECT_ERROR;
LOG_WARN("peer no in communication, maybe crashed", K(ret), K(sqc), K(cluster_id), LOG_WARN("peer no in communication, maybe crashed", K(ret), K(sqc), K(cluster_id),
K(session->get_process_query_time())); K(session->get_process_query_time()));
} else {
LOG_WARN("ignore the black server list with virtual table", K(ret));
} }
}
if (OB_FAIL(ret)) {
} else { } else {
SMART_VAR(ObPxRpcInitSqcArgs, args) { SMART_VAR(ObPxRpcInitSqcArgs, args) {
ObPxRpcInitSqcResponse resp; ObPxRpcInitSqcResponse resp;