File tree Expand file tree Collapse file tree 1 file changed +3
-16
lines changed
src/query/storages/fuse/src/operations/common/processors Expand file tree Collapse file tree 1 file changed +3
-16
lines changed Original file line number Diff line number Diff line change @@ -401,7 +401,8 @@ where F: SnapshotGenerator + Send + 'static
401
401
tbl. table_info. name, tbl. table_info. ident
402
402
) ;
403
403
// pure historical data.
404
- // errors ignored (since it can be picked up by subsequent purge actions)
404
+ // errors are ignored(but logged), since it should not interrupt the main task
405
+ // and could be picked up by subsequent purge actions.
405
406
match tbl
406
407
. navigate_for_purge (
407
408
& self . ctx ,
@@ -434,22 +435,8 @@ where F: SnapshotGenerator + Send + 'static
434
435
) ;
435
436
}
436
437
}
437
-
438
- // let snapshot_files = tbl.list_snapshot_files().await?;
439
-
440
- // if let Err(e) = tbl
441
- // .do_purge(
442
- // &self.ctx,
443
- // snapshot_files,
444
- // None,
445
- // keep_last_snapshot,
446
- // dry_run,
447
- // )
448
- // .await
449
- //{
450
- //} else {
451
- //}
452
438
}
439
+
453
440
metrics_inc_commit_mutation_success ( ) ;
454
441
{
455
442
let elapsed_time = self . start_time . elapsed ( ) . as_millis ( ) ;
You can’t perform that action at this time.
0 commit comments