(beam) branch master updated: Add sleep after update (#35653)

[yhu]

This is an automated email from the ASF dual-hosted git repository.

yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 0e57ef477ca Add sleep after update (#35653)
0e57ef477ca is described below

commit 0e57ef477cabedf1efaa34656c12c54832b75675
Author: Vitaly Terentyev <vitaly.terentyev....@gmail.com>
AuthorDate: Tue Jul 22 17:59:43 2025 +0400

    Add sleep after update (#35653)
---
 .../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) {