use hash shard

risingwavelabs · Jan 29, 2024 · d722b80 · d722b80
1 parent 45b9f35
commit d722b80
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/frontend/src/optimizer/plan_node/logical_join.rs b/src/frontend/src/optimizer/plan_node/logical_join.rs
@@ -1063,7 +1063,7 @@ impl LogicalJoin {
                 .map(|pos| left_eq_indexes[*pos])
                 .collect_vec();
 
-            RequiredDist::shard_by_key(self.left().schema().len(), &left_dist_key)
+            RequiredDist::hash_shard(&left_dist_key)
         };
 
         let left = self.left().to_stream(ctx)?;