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

Fix WhiteScan forward null

Browse Source
This commit is contained in:
tj0
2021-11-15 11:57:40 +08:00
committed by LINxiansheng
parent c84b7de59c
commit 90650d1da6
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/sql/executor/ob_job_parser.cpp
View File

@ -114,11 +114,13 @@ int ObJobParser::split_jobs(ObExecContext& exec_ctx, ObPhysicalPlan* phy_plan, O
job->set_outer_join_child_job(true);
}
}
for (int32_t i = 0; OB_SUCC(ret) && i < phy_op->get_child_num(); ++i) {
if (OB_FAIL(split_jobs(
exec_ctx, phy_plan, phy_op->get_child(i), exec_id, job_ctrl, spfactory, NULL != job ? *job : cur_job))) {
LOG_WARN("fail to split jobs for child op", K(ret), K(exec_id), K(i));
} else {
if (OB_NOT_NULL(phy_op)) {
for (int32_t i = 0; OB_SUCC(ret) && i < phy_op->get_child_num(); ++i) {
if (OB_FAIL(split_jobs(
exec_ctx, phy_plan, phy_op->get_child(i), exec_id, job_ctrl, spfactory, NULL != job ? *job : cur_job))) {
LOG_WARN("fail to split jobs for child op", K(ret), K(exec_id), K(i));
} else {
}
}
}
return ret;