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

[CP] fix null skew handling inconsistant with sharding info

Browse Source
This commit is contained in:
18523270951@163.com
2024-01-12 02:48:10 +00:00
committed by ob-robot
parent c1518248ed
commit 841c6bd2b5
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/share/parameter/ob_parameter_seed.ipp
View File

@ -1604,7 +1604,7 @@ ERRSIM_DEF_STR(errsim_transfer_backfill_server_addr, OB_CLUSTER_PARAMETER, "",
DEF_BOOL(_ob_enable_direct_load, OB_CLUSTER_PARAMETER, "True", DEF_BOOL(_ob_enable_direct_load, OB_CLUSTER_PARAMETER, "True",
"Enable or disable direct path load", "Enable or disable direct path load",
ObParameterAttr(Section::OBSERVER, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE)); ObParameterAttr(Section::OBSERVER, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE));
DEF_BOOL(_px_join_skew_handling, OB_TENANT_PARAMETER, "True", DEF_BOOL(_px_join_skew_handling, OB_TENANT_PARAMETER, "False",
"enables skew handling for parallel joins. The default value is True.", "enables skew handling for parallel joins. The default value is True.",
ObParameterAttr(Section::OBSERVER, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE)); ObParameterAttr(Section::OBSERVER, Source::DEFAULT, EditLevel::DYNAMIC_EFFECTIVE));
DEF_INT(_px_join_skew_minfreq, OB_TENANT_PARAMETER, "30", "[1,100]", DEF_INT(_px_join_skew_minfreq, OB_TENANT_PARAMETER, "30", "[1,100]",

8
src/sql/optimizer/ob_log_plan.cpp
View File

@ -4824,16 +4824,16 @@ void ObLogPlan::compute_null_distribution_info(const ObJoinType &join_type,
right_exch_info.null_row_dist_method_ = ObNullDistributeMethod::DROP; right_exch_info.null_row_dist_method_ = ObNullDistributeMethod::DROP;
break; break;
case ObJoinType::LEFT_OUTER_JOIN: case ObJoinType::LEFT_OUTER_JOIN:
left_exch_info.null_row_dist_method_ = ObNullDistributeMethod::RANDOM; left_exch_info.null_row_dist_method_ = ObNullDistributeMethod::NONE;
right_exch_info.null_row_dist_method_ = ObNullDistributeMethod::DROP; right_exch_info.null_row_dist_method_ = ObNullDistributeMethod::DROP;
break; break;
case ObJoinType::RIGHT_OUTER_JOIN: case ObJoinType::RIGHT_OUTER_JOIN:
left_exch_info.null_row_dist_method_ = ObNullDistributeMethod::DROP; left_exch_info.null_row_dist_method_ = ObNullDistributeMethod::DROP;
right_exch_info.null_row_dist_method_ = ObNullDistributeMethod::RANDOM; right_exch_info.null_row_dist_method_ = ObNullDistributeMethod::NONE;
break; break;
case ObJoinType::FULL_OUTER_JOIN: case ObJoinType::FULL_OUTER_JOIN:
left_exch_info.null_row_dist_method_ = ObNullDistributeMethod::RANDOM; left_exch_info.null_row_dist_method_ = ObNullDistributeMethod::NONE;
right_exch_info.null_row_dist_method_ = ObNullDistributeMethod::RANDOM; right_exch_info.null_row_dist_method_ = ObNullDistributeMethod::NONE;
break; break;
default: default:
left_exch_info.null_row_dist_method_ = ObNullDistributeMethod::NONE; left_exch_info.null_row_dist_method_ = ObNullDistributeMethod::NONE;