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

fix hash hash sharding info bug

Browse Source
This commit is contained in:
Larry955 2022-11-16 13:05:36 +00:00 committed by wangzelin.wzl
parent 63f73fcdc2
commit cd0687afbf
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/sql/optimizer/ob_join_order.cpp
View File

@ -4521,9 +4521,9 @@ int JoinPath::compute_hash_hash_sharding_info()
} else { } else {
target_sharding = new (target_sharding) ObShardingInfo(); target_sharding = new (target_sharding) ObShardingInfo();
target_sharding->set_distributed(); target_sharding->set_distributed();
if (use_left) { if (use_left && FULL_OUTER_JOIN != join_type_ && RIGHT_OUTER_JOIN != join_type_) {
ret = target_sharding->get_partition_keys().assign(left_join_exprs); ret = target_sharding->get_partition_keys().assign(left_join_exprs);
} else if (use_right) { } else if (use_right && FULL_OUTER_JOIN != join_type_ && LEFT_OUTER_JOIN != join_type_) {
ret = target_sharding->get_partition_keys().assign(right_join_exprs); ret = target_sharding->get_partition_keys().assign(right_join_exprs);
} else { /*do nothing*/ } } else { /*do nothing*/ }