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

fix log_exchange compute op_ordering bug

Browse Source
This commit is contained in:
zzg19950727 2024-08-26 08:23:55 +00:00 committed by ob-robot
parent e96f717f75
commit 83350fabe2
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -363,7 +363,9 @@ int ObLogExchange::compute_op_ordering()
} else if (is_producer()) {
// for FULL_INPUT_SAMPLE, we cache all rows in transmit and send in random range
// to avoid send to one worker at one time if input order is the same with %sort_keys_
is_local_order_ = FULL_INPUT_SAMPLE == sample_type_;
if (FULL_INPUT_SAMPLE == sample_type_) {
is_local_order_ = true;
}
} else if (is_consumer()) {
if (is_merge_sort_) {
if (OB_UNLIKELY(sort_keys_.empty())) {