@@ -1219,10 +1219,9 @@ mod tests {
         ]))
     }
 
+    // Local TopK tests use one emitter; shared-filter cases pass the partition count explicitly.
     fn make_topk_filter() -> Arc<RwLock<TopKDynamicFilters>> {
-        Arc::new(RwLock::new(TopKDynamicFilters::new(Arc::new(
-            DynamicFilterPhysicalExpr::new(vec![], lit(true)),
-        ))))
+        make_shared_topk_filter(1)
     }
 
     fn make_shared_topk_filter(
Original file line number	Diff line number	Diff line change
`@@ -1219,10 +1219,9 @@ mod tests {`
`1219`	`1219`	`]))`
`1220`	`1220`	`}`
`1221`	`1221`
	`1222`	`+ // Local TopK tests use one emitter; shared-filter cases pass the partition count explicitly.`
`1222`	`1223`	`fn make_topk_filter() -> Arc<RwLock<TopKDynamicFilters>> {`
`1223`		`- Arc::new(RwLock::new(TopKDynamicFilters::new(Arc::new(`
`1224`		`- DynamicFilterPhysicalExpr::new(vec![], lit(true)),`
`1225`		`- ))))`
	`1224`	`+ make_shared_topk_filter(1)`
`1226`	`1225`	`}`
`1227`	`1226`
`1228`	`1227`	`fn make_shared_topk_filter(`