You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by vt...@apache.org on 2025/07/22 07:31:25 UTC
(beam) 01/01: Add sleep after update
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 <vi...@akvelon.com>
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) {