Skip to content

Commit

Permalink
[fix](Nereids) sink distribute is wrong when table is unpartitioned (a…
Browse files Browse the repository at this point in the history
  • Loading branch information
morrySnow authored Sep 18, 2024
1 parent 956b56c commit 5c70fe3
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -203,7 +203,7 @@ public PhysicalProperties getRequirePhysicalProperties() {
if (distributionInfo instanceof HashDistributionInfo) {
// Do not enable shuffle for duplicate key tables when its tablet num is less than threshold.
if (targetTable.getKeysType() == KeysType.DUP_KEYS) {
final long partitionNums = targetTable.getPartitionInfo().getAllPartitions().size();
final long partitionNums = Math.max(targetTable.getPartitionInfo().getAllPartitions().size(), 1);
final long tabletNums = partitionNums * distributionInfo.getBucketNum();
if (tabletNums < Config.min_tablets_for_dup_table_shuffle) {
return PhysicalProperties.ANY;
Expand Down

0 comments on commit 5c70fe3

Please sign in to comment.