From 85ea89db36128f2e96ef5bff14f026b821c5f29a Mon Sep 17 00:00:00 2001 From: Sreesh Maheshwar Date: Tue, 20 Jan 2026 10:29:34 +0000 Subject: [PATCH] [Test] Test concurrent replace snapshot preservation --- core/src/test/java/org/apache/iceberg/catalog/CatalogTests.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/core/src/test/java/org/apache/iceberg/catalog/CatalogTests.java b/core/src/test/java/org/apache/iceberg/catalog/CatalogTests.java index 833b2fb0b46f..b3318170a66d 100644 --- a/core/src/test/java/org/apache/iceberg/catalog/CatalogTests.java +++ b/core/src/test/java/org/apache/iceberg/catalog/CatalogTests.java @@ -2691,6 +2691,8 @@ public void testConcurrentReplaceTransactions() { secondReplace.commitTransaction(); Table afterSecondReplace = catalog.loadTable(TABLE); + // All three successfully committed snapshots should be present + assertThat(afterSecondReplace.snapshots()).hasSize(3); assertThat(afterSecondReplace.schema().asStruct()) .as("Table schema should match the original schema") .isEqualTo(original.schema().asStruct());