tool
/
starrocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[BugFix] set bucket_aware for shuffler (#61801) 

Signed-off-by: zombee0 <ewang2027@gmail.com>
This commit is contained in:
zombee0 2025-08-12 14:13:15 +08:00 committed by GitHub
parent 47ebfde44e
commit b9dbceaa2b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
be/src/exec/pipeline/exchange/exchange_sink_operator.cpp
View File

@ -387,7 +387,8 @@ ExchangeSinkOperator::ExchangeSinkOperator(
_is_pipeline_level_shuffle = is_pipeline_level_shuffle && (_num_shuffles > 1);
_shuffler = std::make_unique<Shuffler>(runtime_state()->func_version() <= 3, !_is_channel_bound_driver_sequence,
_part_type, _channels.size(), _num_shuffles_per_channel);
_part_type, _channels.size(), _num_shuffles_per_channel,
!bucket_properties.empty());
}
Status ExchangeSinkOperator::prepare(RuntimeState* state) {

2
be/src/exec/pipeline/exchange/shuffler.h
View File

@ -104,6 +104,6 @@ private:
const TPartitionType::type _part_type = TPartitionType::UNPARTITIONED;
const size_t _num_channels;
const size_t _num_shuffles_per_channel;
bool _bucket_aware;
const bool _bucket_aware;
};
} // namespace starrocks::pipeline