[hotfix] Don't print waiting info in waitForNextWithTimeout & try to fix unstable testCreateAlreadyExistsLakeTable (apache#1650)

Author: luoyuxia

fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalogTest.java

@@ -272,24 +272,20 @@ void testCreateAlreadyExistsLakeTable() throws Exception {
         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

fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/testutils/FlinkRowAssertionsUtils.java

@@ -164,11 +164,9 @@ private static AssertionError timeoutError(
     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) {