We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 175e301 commit f052239Copy full SHA for f052239
1 file changed
quickwit/quickwit-indexing/src/actors/metrics_pipeline/parquet_merge_pipeline.rs
@@ -305,9 +305,9 @@ impl ParquetMergePipeline {
305
.set_kill_switch(self.kill_switch.clone())
306
.spawn(merge_split_downloader);
307
308
- // 6. Merge planner — uses recycled mailbox/inbox so the publisher's
309
- // feedback loop (which holds a clone of the planner mailbox) survives
310
- // pipeline restarts without needing to be re-wired.
+ // 6. Merge planner — uses recycled mailbox/inbox so the publisher's feedback loop (which
+ // holds a clone of the planner mailbox) survives pipeline restarts without needing to be
+ // re-wired.
311
let merge_planner = ParquetMergePlanner::new(
312
immature_splits,
313
self.params.merge_policy.clone(),
0 commit comments