From d722b80e181494f31921f28161b4046d627b8db3 Mon Sep 17 00:00:00 2001 From: Dylan Chen Date: Mon, 29 Jan 2024 23:56:16 +0800 Subject: [PATCH] use hash shard --- src/frontend/src/optimizer/plan_node/logical_join.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/frontend/src/optimizer/plan_node/logical_join.rs b/src/frontend/src/optimizer/plan_node/logical_join.rs index a5be7e1fb0368..0b83e2491ce99 100644 --- 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)?;