@@ -128,6 +128,7 @@ async fn truncated_commit_log(log_segment: LogSegment, log_store: &dyn LogStore,
128128 . to_vec ( )
129129 } ;
130130 let mut truncated_log_size = 0_u64 ; // keep track of the total size to cut it shorter if needed
131+ let latest_commit_file = truncated_log. last ( ) . cloned ( ) ;
131132 Ok ( LogSegment {
132133 end_version : log_segment. end_version ,
133134 ascending_commit_files : truncated_log. into_iter ( )
@@ -145,7 +146,7 @@ async fn truncated_commit_log(log_segment: LogSegment, log_store: &dyn LogStore,
145146 log_root : log_store. log_root_url ( ) ,
146147 checkpoint_version : None ,
147148 latest_crc_file : None ,
148- latest_commit_file : None ,
149+ latest_commit_file,
149150 } )
150151}
151152
@@ -669,7 +670,7 @@ mod tests {
669670 log_root: log_store. log_root_url( ) ,
670671 checkpoint_version: None ,
671672 latest_crc_file: None ,
672- latest_commit_file: None ,
673+ latest_commit_file: Some ( parsed_log_path ( "delta_table/_delta_log/00000000000000000005.json" , 128 ) ) ,
673674 }
674675 ) ;
675676
@@ -691,7 +692,7 @@ mod tests {
691692 log_root: log_store. log_root_url( ) ,
692693 checkpoint_version: Some ( 30 ) ,
693694 latest_crc_file: None ,
694- latest_commit_file: None ,
695+ latest_commit_file: Some ( parsed_log_path ( "delta_table/_delta_log/00000000000000000032.json" , 128 ) ) ,
695696 }
696697 ) ;
697698
@@ -718,7 +719,7 @@ mod tests {
718719 log_root: log_store. log_root_url( ) ,
719720 checkpoint_version: Some ( 90 ) ,
720721 latest_crc_file: None ,
721- latest_commit_file: None ,
722+ latest_commit_file: Some ( parsed_log_path ( "delta_table/_delta_log/00000000000000000097.json" , 128 ) , ) ,
722723 }
723724 ) ;
724725
0 commit comments