From 9a6b24b06d2e538eddb2e646e4db866a101efe34 Mon Sep 17 00:00:00 2001 From: Rion Williams Date: Sat, 27 Dec 2025 10:55:59 -0600 Subject: [PATCH] [FLUSS-2262][lake] Improved Stability for Iceberg Log Table Compaction Test --- .../fluss/lake/iceberg/maintenance/IcebergRewriteITCase.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/fluss-lake/fluss-lake-iceberg/src/test/java/org/apache/fluss/lake/iceberg/maintenance/IcebergRewriteITCase.java b/fluss-lake/fluss-lake-iceberg/src/test/java/org/apache/fluss/lake/iceberg/maintenance/IcebergRewriteITCase.java index 4b6d9de71a..44f4a848ea 100644 --- a/fluss-lake/fluss-lake-iceberg/src/test/java/org/apache/fluss/lake/iceberg/maintenance/IcebergRewriteITCase.java +++ b/fluss-lake/fluss-lake-iceberg/src/test/java/org/apache/fluss/lake/iceberg/maintenance/IcebergRewriteITCase.java @@ -186,6 +186,9 @@ void testLogTableCompaction() throws Exception { t1, t1Bucket, ++i, true, Collections.singletonList(row(1, "v1")))); checkFileStatusInIcebergTable(t1, 3, false); + // Ensure tiering job has fully processed the previous writes + assertReplicaStatus(t1Bucket, i); + // Write should trigger compaction now since the current data file count is greater or // equal MIN_FILES_TO_COMPACT flussRows.addAll(