@@ -373,7 +373,7 @@ impl HotTierManager {
373
373
* parquet_file_size += parquet_file. file_size ;
374
374
stream_hot_tier. used_size = * parquet_file_size;
375
375
376
- stream_hot_tier. available_size = stream_hot_tier . available_size - parquet_file. file_size ;
376
+ stream_hot_tier. available_size -= parquet_file. file_size ;
377
377
self . put_hot_tier ( stream, & mut stream_hot_tier) . await ?;
378
378
file_processed = true ;
379
379
let path = self . get_stream_path_for_date ( stream, & date) ;
@@ -400,7 +400,7 @@ impl HotTierManager {
400
400
dates : & [ NaiveDate ] ,
401
401
) -> Result < ( ) , HotTierError > {
402
402
for date in dates. iter ( ) {
403
- let path = self . get_stream_path_for_date ( stream, & date) ;
403
+ let path = self . get_stream_path_for_date ( stream, date) ;
404
404
if path. exists ( ) {
405
405
fs:: remove_dir_all ( path. clone ( ) ) . await ?;
406
406
}
@@ -594,8 +594,8 @@ impl HotTierManager {
594
594
fs:: remove_dir_all ( path_to_delete. parent ( ) . unwrap ( ) ) . await ?;
595
595
delete_empty_directory_hot_tier ( path_to_delete. parent ( ) . unwrap ( ) ) . await ?;
596
596
597
- stream_hot_tier. used_size = stream_hot_tier . used_size - file_size;
598
- stream_hot_tier. available_size = stream_hot_tier . available_size + file_size;
597
+ stream_hot_tier. used_size -= file_size;
598
+ stream_hot_tier. available_size += file_size;
599
599
self . put_hot_tier ( stream, stream_hot_tier) . await ?;
600
600
delete_successful = true ;
601
601
0 commit comments