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

fix generate partition join filter plan bug

Browse Source
This commit is contained in:
zzg19950727
2023-05-08 02:38:37 +00:00
committed by ob-robot
parent cbc4f744dd
commit 1d1d1e009e
11 changed files with 61 additions and 91 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/sql/optimizer/ob_select_log_plan.cpp
View File

@ -2969,7 +2969,7 @@ int ObSelectLogPlan::get_distributed_set_methods(const EqualSets &equal_sets,
set_dist_methods &= ~DistAlgo::DIST_PARTITION_NONE;
OPT_TRACE("plan will not use partition none method");
} else {
need_pull_to_local = right_child.get_contains_pw_merge_op() && GET_MIN_CLUSTER_VERSION() < CLUSTER_VERSION_4_1_0_0;
need_pull_to_local = false;
set_dist_methods &= ~DistAlgo::DIST_HASH_NONE;
OPT_TRACE("plan will use partition none method");
}
@ -3005,7 +3005,7 @@ int ObSelectLogPlan::get_distributed_set_methods(const EqualSets &equal_sets,
set_dist_methods &= ~DistAlgo::DIST_NONE_PARTITION;
OPT_TRACE("plan will not use none partition method");
} else {
need_pull_to_local = left_child.get_contains_pw_merge_op() && GET_MIN_CLUSTER_VERSION() < CLUSTER_VERSION_4_1_0_0;
need_pull_to_local = false;
set_dist_methods &= ~DistAlgo::DIST_NONE_HASH;
OPT_TRACE("plan will use none partition method");
}
@ -3059,9 +3059,9 @@ bool ObSelectLogPlan::is_set_repart_valid(const ObLogicalOperator &left_plan,
{
bool is_valid = true;
if (DistAlgo::DIST_PARTITION_NONE == dist_algo && right_plan.get_contains_pw_merge_op()) {
is_valid = GET_MIN_CLUSTER_VERSION() >= CLUSTER_VERSION_4_1_0_0;
is_valid = true;
} else if (DistAlgo::DIST_NONE_PARTITION == dist_algo && left_plan.get_contains_pw_merge_op()) {
is_valid = GET_MIN_CLUSTER_VERSION() >= CLUSTER_VERSION_4_1_0_0;
is_valid = true;
} else {
is_valid = true;
}
@ -5203,8 +5203,6 @@ int ObSelectLogPlan::check_winfunc_pushdown(
if (OB_ISNULL(top)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("top is null", K(ret));
} else if (GET_MIN_CLUSTER_VERSION() < CLUSTER_VERSION_4_1_0_0) {
is_pushdown = false;
} else if (WinDistAlgo::HASH != method) {
is_pushdown = false;
} else {