File tree Expand file tree Collapse file tree 1 file changed +13
-2
lines changed Expand file tree Collapse file tree 1 file changed +13
-2
lines changed Original file line number Diff line number Diff line change @@ -657,6 +657,7 @@ impl<RT: Runtime> IndexWriter<RT> {
657
657
. fuse ( ) ;
658
658
pin_mut ! ( stream) ;
659
659
let mut index_updates_written = 0 ;
660
+ let mut last_logged = self . runtime . system_time ( ) ;
660
661
while !stream. is_done ( ) {
661
662
let mut chunk = BTreeSet :: new ( ) ;
662
663
while chunk. len ( ) < * INDEX_BACKFILL_CHUNK_SIZE {
@@ -678,8 +679,18 @@ impl<RT: Runtime> IndexWriter<RT> {
678
679
. write ( vec ! [ ] , chunk, ConflictStrategy :: Overwrite )
679
680
. await ?;
680
681
}
682
+ if last_logged. elapsed ( ) ? >= Duration :: from_secs ( 60 ) {
683
+ tracing:: info!(
684
+ "backfilled {index_updates_written} index rows for table {table_id} at \
685
+ snapshot {snapshot_ts}",
686
+ ) ;
687
+ last_logged = self . runtime . system_time ( ) ;
688
+ }
681
689
}
682
- tracing:: info!( "backfilled {index_updates_written} index rows at snapshot {snapshot_ts}" ) ;
690
+ tracing:: info!(
691
+ "backfilled {index_updates_written} index rows for table {table_id} at snapshot \
692
+ {snapshot_ts}"
693
+ ) ;
683
694
Ok ( ( ) )
684
695
}
685
696
@@ -892,7 +903,7 @@ impl<RT: Runtime> IndexWriter<RT> {
892
903
self . persistence
893
904
. write ( vec ! [ ] , chunk, ConflictStrategy :: Overwrite )
894
905
. await ?;
895
- if last_logged. elapsed ( ) ? >= Duration :: from_secs ( 10 ) {
906
+ if last_logged. elapsed ( ) ? >= Duration :: from_secs ( 60 ) {
896
907
log:: info!(
897
908
"Backfilled {} index entries of index {}" ,
898
909
num_entries_written,
You can’t perform that action at this time.
0 commit comments