[incubator-paimon] branch master updated: [test] Fix unstable test: testCompactionInStreamingMode (#1651)

[lzljs3620320]

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

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new d758771d1 [test] Fix unstable test: testCompactionInStreamingMode 
(#1651)
d758771d1 is described below

commit d758771d183e005ec1422086db1cb2f61cdca4a0
Author: YeJunHao <41894543+leaves12...@users.noreply.github.com>
AuthorDate: Fri Jul 28 15:56:30 2023 +0800

    [test] Fix unstable test: testCompactionInStreamingMode (#1651)
---
 .../org/apache/paimon/flink/UnawareBucketAppendOnlyTableITCase.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/UnawareBucketAppendOnlyTableITCase.java
 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/UnawareBucketAppendOnlyTableITCase.java
index 8e3840eca..0b75de2ea 100644
--- 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/UnawareBucketAppendOnlyTableITCase.java
+++ 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/UnawareBucketAppendOnlyTableITCase.java
@@ -197,13 +197,15 @@ public class UnawareBucketAppendOnlyTableITCase extends 
CatalogITCaseBase {
                         + ") WITH (\n"
                         + "    'connector' = 'datagen',\n"
                         + "    'rows-per-second' = '1',\n"
-                        + "    'number-of-rows' = '4'\n"
+                        + "    'number-of-rows' = '10'\n"
                         + ")");
 
         assertStreamingHasCompact("INSERT INTO append_table SELECT * FROM 
Orders_in", 60000);
+        // ensure data gen finished
+        Thread.sleep(5000);
 
         List<Row> rows = batchSql("SELECT * FROM append_table");
-        assertThat(rows.size()).isEqualTo(4);
+        assertThat(rows.size()).isEqualTo(10);
     }
 
     @Test