Fix bad merge: mark complete

LiaCastaneda · LiaCastaneda · commit fbb14e479b48 · 2025-12-17T15:08:13.000+01:00
diff --git a/datafusion/physical-plan/src/joins/hash_join/shared_bounds.rs b/datafusion/physical-plan/src/joins/hash_join/shared_bounds.rs
@@ -578,6 +578,7 @@ impl SharedBuildAccumulator {
                     }
                 }
             }
+            self.dynamic_filter.mark_complete();
         }
 
         Ok(())

Original file line number	Diff line number	Diff line change
`@@ -578,6 +578,7 @@ impl SharedBuildAccumulator {`
`578`	`578`	`}`
`579`	`579`	`}`
`580`	`580`	`}`
	`581`	`+ self.dynamic_filter.mark_complete();`
`581`	`582`	`}`
`582`	`583`
`583`	`584`	`Ok(())`