(fluss) branch main updated: [hotfix] Don't print waiting info in waitForNextWithTimeout & try to fix unstable testCreateAlreadyExistsLakeTable (#1650)

[yuxia]

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

yuxia 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 58292a019 [hotfix] Don't print waiting info in waitForNextWithTimeout 
& try to fix unstable testCreateAlreadyExistsLakeTable (#1650)
58292a019 is described below

commit 58292a0192eb9414103e683fa3671b1a2e5cff91
Author: yuxia Luo <luoyu...@alumni.sjtu.edu.cn>
AuthorDate: Fri Sep 5 18:18:25 2025 +0800

    [hotfix] Don't print waiting info in waitForNextWithTimeout & try to fix 
unstable testCreateAlreadyExistsLakeTable (#1650)
---
 .../apache/fluss/flink/catalog/FlinkCatalogTest.java   | 18 +++++++-----------
 .../source/testutils/FlinkRowAssertionsUtils.java      |  2 --
 2 files changed, 7 insertions(+), 13 deletions(-)

diff --git 
a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalogTest.java
 
b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalogTest.java
index ce9ee048b..46dfa8b23 100644
--- 
a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalogTest.java
+++ 
b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalogTest.java
@@ -272,24 +272,20 @@ class FlinkCatalogTest {
         Map<String, String> options = new HashMap<>();
         options.put(TABLE_DATALAKE_ENABLED.key(), "true");
         options.put(TABLE_DATALAKE_FORMAT.key(), PAIMON.name());
-        assertThatThrownBy(() -> catalog.getTable(tableInDefaultDb))
-                .isInstanceOf(TableNotExistException.class)
-                .hasMessage(
-                        String.format(
-                                "Table (or view) %s does not exist in Catalog 
%s.",
-                                tableInDefaultDb, CATALOG_NAME));
+
+        ObjectPath lakeTablePath = new ObjectPath(DEFAULT_DB, "lake_table");
         CatalogTable table = this.newCatalogTable(options);
-        catalog.createTable(this.tableInDefaultDb, table, false);
-        assertThat(catalog.tableExists(this.tableInDefaultDb)).isTrue();
+        catalog.createTable(lakeTablePath, table, false);
+        assertThat(catalog.tableExists(lakeTablePath)).isTrue();
         // drop fluss table
-        catalog.dropTable(this.tableInDefaultDb, false);
+        catalog.dropTable(lakeTablePath, false);
         // create the table again, should throw exception with ignore if exist 
= false
-        assertThatThrownBy(() -> catalog.createTable(this.tableInDefaultDb, 
table, false))
+        assertThatThrownBy(() -> catalog.createTable(lakeTablePath, table, 
false))
                 .isInstanceOf(CatalogException.class)
                 .hasMessage(
                         String.format(
                                 "The table %s already exists in %s catalog, 
please first drop the table in %s catalog or use a new table name.",
-                                this.tableInDefaultDb, "paimon", "paimon"));
+                                lakeTablePath, "paimon", "paimon"));
     }
 
     @Test
diff --git 
a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/testutils/FlinkRowAssertionsUtils.java
 
b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/testutils/FlinkRowAssertionsUtils.java
index 5946d906c..772201dab 100644
--- 
a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/testutils/FlinkRowAssertionsUtils.java
+++ 
b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/testutils/FlinkRowAssertionsUtils.java
@@ -164,11 +164,9 @@ public class FlinkRowAssertionsUtils {
     private static boolean waitForNextWithTimeout(
             CloseableIterator<Row> iterator, long maxWaitTime) {
         CompletableFuture<Boolean> future = 
CompletableFuture.supplyAsync(iterator::hasNext);
-        System.out.println("Waiting for " + maxWaitTime + " ms to finish.");
         try {
             return future.get(maxWaitTime, TimeUnit.MILLISECONDS);
         } catch (TimeoutException e) {
-            System.err.println("Timeout waiting for " + maxWaitTime + " ms to 
finish.");
             future.cancel(true);
             return false;
         } catch (Exception e) {