Merge branch 'JanKaul:main' into main

Author: gruuya

iceberg-rust/src/catalog/commit.rs

@@ -513,6 +513,10 @@ pub fn apply_table_updates(
                 for id in snapshot_ids {
                     metadata.snapshots.remove(&id);
                 }
+
+                metadata
+                    .snapshot_log
+                    .retain(|e| metadata.snapshots.contains_key(&e.snapshot_id));
             }
             TableUpdate::RemoveSnapshotRef { ref_name } => {
                 metadata.refs.remove(&ref_name);

iceberg-rust/src/table/manifest.rs

@@ -386,8 +386,12 @@ impl<'schema, 'metadata> ManifestWriter<'schema, 'metadata> {
         manifest.existing_files_count = Some(
             manifest.existing_files_count.unwrap_or(0) + manifest.added_files_count.unwrap_or(0),
         );
+        manifest.existing_rows_count = Some(
+            manifest.existing_rows_count.unwrap_or(0) + manifest.added_rows_count.unwrap_or(0),
+        );
 
         manifest.added_files_count = None;
+        manifest.added_rows_count = None;
 
         Ok(ManifestWriter {
             manifest,
@@ -525,10 +529,16 @@ impl<'schema, 'metadata> ManifestWriter<'schema, 'metadata> {
         manifest.sequence_number = table_metadata.last_sequence_number + 1;
 
         manifest.existing_files_count = Some(
-            manifest.existing_files_count.unwrap_or(0) + manifest.added_files_count.unwrap_or(0),
+            manifest.existing_files_count.unwrap_or(0) + manifest.added_files_count.unwrap_or(0)
+                - filtered_stats.removed_data_files,
+        );
+        manifest.existing_rows_count = Some(
+            manifest.existing_rows_count.unwrap_or(0) + manifest.added_rows_count.unwrap_or(0)
+                - filtered_stats.removed_records,
         );
 
         manifest.added_files_count = None;
+        manifest.added_rows_count = None;
 
         Ok((
             ManifestWriter {