@@ -822,6 +822,12 @@ where
822
822
Some ( task) => task,
823
823
} ;
824
824
compact_task. watermark = watermark;
825
+ compact_task. existing_table_ids = current_version
826
+ . levels
827
+ . get ( & compaction_group_id)
828
+ . unwrap ( )
829
+ . member_table_ids
830
+ . clone ( ) ;
825
831
826
832
if CompactStatus :: is_trivial_move_task ( & compact_task) && can_trivial_move {
827
833
compact_task. sorted_output_ssts = compact_task. input_ssts [ 0 ] . table_infos . clone ( ) ;
@@ -838,13 +844,6 @@ where
838
844
start_time. elapsed( )
839
845
) ;
840
846
} else {
841
- // to get all relational table_id from sst_info
842
- compact_task. existing_table_ids = current_version
843
- . levels
844
- . get ( & compaction_group_id)
845
- . unwrap ( )
846
- . member_table_ids
847
- . clone ( ) ;
848
847
compact_task. table_options = table_id_to_option
849
848
. into_iter ( )
850
849
. filter_map ( |( table_id, table_option) | {
@@ -1142,6 +1141,7 @@ where
1142
1141
}
1143
1142
}
1144
1143
let is_success = if let TaskStatus :: Success = compact_task. task_status ( ) {
1144
+ // if member_table_ids changes, the data of sstable may stale.
1145
1145
let is_expired = current_version
1146
1146
. levels
1147
1147
. get ( & compact_task. compaction_group_id )
@@ -1987,7 +1987,7 @@ where
1987
1987
. scale_compactor_core_num
1988
1988
. set ( suggest_scale_out_core as i64 ) ;
1989
1989
1990
- tracing:: info !(
1990
+ tracing:: debug !(
1991
1991
"report_scale_compactor_info {:?} suggest_scale_out_core {:?}" ,
1992
1992
info,
1993
1993
suggest_scale_out_core
0 commit comments