File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -575,7 +575,12 @@ impl HotTierManager {
575575 stream : & str ,
576576 manifest_files : Vec < File > ,
577577 ) -> Result < ( Vec < File > , Vec < File > ) , HotTierError > {
578- let hot_tier_files = self . get_hot_tier_parquet_files ( stream) . await ?;
578+ let mut hot_tier_files = self . get_hot_tier_parquet_files ( stream) . await ?;
579+ hot_tier_files. retain ( |file| {
580+ manifest_files
581+ . iter ( )
582+ . any ( |manifest_file| manifest_file. file_path . eq ( & file. file_path ) )
583+ } ) ;
579584 let remaining_files: Vec < File > = manifest_files
580585 . into_iter ( )
581586 . filter ( |manifest_file| {
@@ -584,7 +589,6 @@ impl HotTierManager {
584589 . all ( |file| !file. file_path . eq ( & manifest_file. file_path ) )
585590 } )
586591 . collect ( ) ;
587-
588592 Ok ( ( hot_tier_files, remaining_files) )
589593 }
590594
You can’t perform that action at this time.
0 commit comments