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<InternalRow> initialRows = Arrays.asList(row(1, "v1"), row(2, "v2"));