Skip to content

Commit f668d1c

Browse files
committed
fix
1 parent 2a808bf commit f668d1c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/query/sql/src/executor/physical_plans/physical_hash_join.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -636,7 +636,7 @@ impl PhysicalPlanBuilder {
636636

637637
let enable_bloom_runtime_filter = {
638638
// shuffle join does not support bloom runtime filter for now
639-
let is_shuffle = self.ctx.get_cluster().is_empty() && !is_broadcast;
639+
let is_shuffle = !self.ctx.get_cluster().is_empty() && !is_broadcast;
640640
let is_supported_type = data_type.is_number() || data_type.is_string();
641641
let enable_bloom_runtime_filter_based_on_stats = adjust_bloom_runtime_filter(
642642
self.ctx.clone(),

0 commit comments

Comments
 (0)