This is an automated email from the ASF dual-hosted git repository. vterentev pushed a commit to branch fix-iceberg-it in repository https://gitbox.apache.org/repos/asf/beam.git
commit f8ec7aef8a8761767e56cff0c0d855ce8ea63093 Author: Vitaly Terentyev <[email protected]> AuthorDate: Tue Jul 22 09:45:15 2025 +0400 Add sleep after update --- .../org/apache/beam/sdk/io/iceberg/catalog/IcebergCatalogBaseIT.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/catalog/IcebergCatalogBaseIT.java b/sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/catalog/IcebergCatalogBaseIT.java index 70ea9206c11..95404ff4026 100644 --- a/sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/catalog/IcebergCatalogBaseIT.java +++ b/sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/catalog/IcebergCatalogBaseIT.java @@ -141,6 +141,7 @@ import org.slf4j.LoggerFactory; */ public abstract class IcebergCatalogBaseIT implements Serializable { private static final long SETUP_TEARDOWN_SLEEP_MS = 5000; + private static final long AFTER_UPDATE_SLEEP_MS = 2000; public abstract Catalog createCatalog(); @@ -956,11 +957,15 @@ public abstract class IcebergCatalogBaseIT implements Serializable { Table table = catalog.createTable(TableIdentifier.parse(tableId()), ICEBERG_SCHEMA); populateTable(table, "a"); // first snapshot + Thread.sleep(AFTER_UPDATE_SLEEP_MS); List<Row> expectedRows = populateTable(table, "b"); // second snapshot Snapshot from = table.currentSnapshot(); + Thread.sleep(AFTER_UPDATE_SLEEP_MS); expectedRows.addAll(populateTable(table, "c")); // third snapshot Snapshot to = table.currentSnapshot(); + Thread.sleep(AFTER_UPDATE_SLEEP_MS); populateTable(table, "d"); // fourth snapshot + Thread.sleep(AFTER_UPDATE_SLEEP_MS); Map<String, Object> config = new HashMap<>(managedIcebergConfig(tableId())); if (useSnapshotBoundary) {
