Merge pull request JanKaul#244 from gruuya/last-updated-ms-fix

fix: update `last-updated-ms` field when updating a table

Author: JanKaul

iceberg-rust/src/catalog/commit.rs

@@ -9,8 +9,6 @@
 //! All changes are made atomically - either all updates succeed or none are applied.
 //! Requirements are checked first to ensure concurrent modifications don't corrupt state.
 
-use std::collections::HashMap;
-
 use iceberg_rust_spec::{
     spec::{
         partition::PartitionSpec,
@@ -24,6 +22,8 @@ use iceberg_rust_spec::{
     view_metadata::Materialization,
 };
 use serde_derive::{Deserialize, Serialize};
+use std::collections::HashMap;
+use std::time::{SystemTime, UNIX_EPOCH};
 use uuid::Uuid;
 
 use crate::error::Error;
@@ -530,6 +530,12 @@ pub fn apply_table_updates(
             }
         };
     }
+
+    // Lastly make sure `last-updated-ms` field is up-to-date
+    metadata.last_updated_ms = SystemTime::now()
+        .duration_since(UNIX_EPOCH)
+        .unwrap()
+        .as_millis() as i64;
     Ok(())
 }
 

iceberg-rust/tests/overwrite_test.rs

@@ -83,6 +83,8 @@ async fn test_table_transaction_overwrite() {
         .await
         .expect("Failed to create table");
 
+    let mut previous_last_updated_ms = table.metadata().last_updated_ms;
+
     // 4. Create initial Arrow RecordBatch and write to parquet
     let initial_batch = create_initial_record_batch();
     let initial_stream = stream::iter(vec![Ok(initial_batch.clone())]);
@@ -104,6 +106,8 @@ async fn test_table_transaction_overwrite() {
         !table.metadata().snapshots.is_empty(),
         "Table should have at least one snapshot after append"
     );
+    assert!(table.metadata().last_updated_ms > previous_last_updated_ms);
+    previous_last_updated_ms = table.metadata().last_updated_ms;
 
     // 6. Create overwrite RecordBatch with additional rows
     let overwrite_batch = create_overwrite_record_batch();
@@ -134,6 +138,7 @@ async fn test_table_transaction_overwrite() {
         final_snapshots.len() >= 2,
         "Table should have at least 2 snapshots after overwrite"
     );
+    assert!(table.metadata().last_updated_ms > previous_last_updated_ms);
 
     // Get the current snapshot (should be the overwrite snapshot)
     let current_snapshot = table