(fluss) branch main updated: [test] Fix failed testPkCompactedPollFromLatestNoRecords. (#2465)

[jark]

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

jark pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 6e014ad2b [test] Fix failed testPkCompactedPollFromLatestNoRecords. 
(#2465)
6e014ad2b is described below

commit 6e014ad2b81446bafa1d0fcf8162fee96581d709
Author: SeungMin <semi...@gmail.com>
AuthorDate: Sun Jan 25 01:06:53 2026 +0900

    [test] Fix failed testPkCompactedPollFromLatestNoRecords. (#2465)
---
 .../src/test/java/org/apache/fluss/client/table/FlussTableITCase.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/fluss-client/src/test/java/org/apache/fluss/client/table/FlussTableITCase.java
 
b/fluss-client/src/test/java/org/apache/fluss/client/table/FlussTableITCase.java
index c21c6a8bb..1dcb0fe7c 100644
--- 
a/fluss-client/src/test/java/org/apache/fluss/client/table/FlussTableITCase.java
+++ 
b/fluss-client/src/test/java/org/apache/fluss/client/table/FlussTableITCase.java
@@ -1748,7 +1748,8 @@ class FlussTableITCase extends ClientToServerITCaseBase {
                         .logFormat(LogFormat.COMPACTED)
                         .build();
         TablePath path = TablePath.of("test_db_1", "test_pk_compacted_latest");
-        createTable(path, td, false);
+        long tableId = createTable(path, td, false);
+        FLUSS_CLUSTER_EXTENSION.waitUntilTableReady(tableId);
 
         try (Table table = conn.getTable(path)) {
             LogScanner scanner = createLogScanner(table);