From 1406b6ec0c223f692359a83d5bc5b25d73313a8b Mon Sep 17 00:00:00 2001 From: chengjiechengjie Date: Fri, 4 Sep 2026 15:47:11 +0800 Subject: [PATCH] [test] Fix flaky testUnionReadWithCustomLakeTablePath test --- .../lake/paimon/flink/FlinkUnionReadPrimaryKeyTableITCase.java | 1 + 1 file changed, 1 insertion(+) diff --git a/fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/flink/FlinkUnionReadPrimaryKeyTableITCase.java b/fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/flink/FlinkUnionReadPrimaryKeyTableITCase.java index fbeab177737..1b25963ae00 100644 --- a/fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/flink/FlinkUnionReadPrimaryKeyTableITCase.java +++ b/fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/flink/FlinkUnionReadPrimaryKeyTableITCase.java @@ -1065,6 +1065,7 @@ void testUnionReadWithCustomLakeTablePath() throws Exception { ConfigOptions.TABLE_DATALAKE_TABLE_NAME.key(), lakeTablePath.getTableName()); long tableId = createPkTable(tablePath, tableProperties, Collections.emptyMap()); + FLUSS_CLUSTER_EXTENSION.waitUntilTableReady(tableId); TableBucket tableBucket = new TableBucket(tableId, 0); List initialRows = Arrays.asList(row(1, "v1"), row(2, "v2"));