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());