simplify

adriangb · adriangb · commit 13a6ee6367ee · 2025-08-15T13:31:06.000-05:00
diff --git a/datafusion/physical-plan/src/joins/hash_join.rs b/datafusion/physical-plan/src/joins/hash_join.rs
@@ -1120,7 +1120,6 @@ impl ExecutionPlan for HashJoinExec {
             bounds_accumulator: Arc::clone(&self.bounds_accumulator),
             dynamic_filter: enable_dynamic_filter_pushdown
                 .then_some(Arc::clone(&self.dynamic_filter)),
-            partition_id: partition,
         }))
     }
 
@@ -1620,8 +1619,6 @@ struct HashJoinStream {
     bounds_accumulator: Arc<SharedBoundsAccumulator>,
     /// Dynamic filter for pushdown to probe side
     dynamic_filter: Option<Arc<DynamicFilterPhysicalExpr>>,
-    /// Partition ID for tracking in bounds accumulator
-    partition_id: usize,
 }
 
 impl RecordBatchStream for HashJoinStream {

Original file line number	Diff line number	Diff line change
`@@ -1120,7 +1120,6 @@ impl ExecutionPlan for HashJoinExec {`
`1120`	`1120`	`bounds_accumulator: Arc::clone(&self.bounds_accumulator),`
`1121`	`1121`	`dynamic_filter: enable_dynamic_filter_pushdown`
`1122`	`1122`	`.then_some(Arc::clone(&self.dynamic_filter)),`
`1123`		`- partition_id: partition,`
`1124`	`1123`	`}))`
`1125`	`1124`	`}`
`1126`	`1125`
`@@ -1620,8 +1619,6 @@ struct HashJoinStream {`
`1620`	`1619`	`bounds_accumulator: Arc<SharedBoundsAccumulator>,`
`1621`	`1620`	`/// Dynamic filter for pushdown to probe side`
`1622`	`1621`	`dynamic_filter: Option<Arc<DynamicFilterPhysicalExpr>>,`
`1623`		`- /// Partition ID for tracking in bounds accumulator`
`1624`		`- partition_id: usize,`
`1625`	`1622`	`}`
`1626`	`1623`
`1627`	`1624`	`impl RecordBatchStream for HashJoinStream {`