(incubator-paimon) branch master updated: [test] Fix unstable test of parallelism set error. (#2626)

[yuzelin]

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

yuzelin 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 99602b6e3 [test] Fix unstable test of parallelism set error. (#2626)
99602b6e3 is described below

commit 99602b6e3a2e7cb11e20277f8abced902618f672
Author: YeJunHao <41894543+leaves12...@users.noreply.github.com>
AuthorDate: Wed Jan 3 17:42:24 2024 +0800

    [test] Fix unstable test of parallelism set error. (#2626)
---
 .../src/test/java/org/apache/paimon/flink/sink/CompactorSinkITCase.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/CompactorSinkITCase.java
 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/CompactorSinkITCase.java
index ffb6f961a..8d5e6c781 100644
--- 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/CompactorSinkITCase.java
+++ 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/CompactorSinkITCase.java
@@ -170,7 +170,7 @@ public class CompactorSinkITCase extends AbstractTestBase {
                         .withContinuousMode(false)
                         .withPartitions(getSpecifiedPartitions())
                         .build();
-        Integer sinkParalellism = new Random().nextInt(100);
+        Integer sinkParalellism = new Random().nextInt(100) + 1;
         new CompactorSinkBuilder(
                         table.copy(
                                 new HashMap<String, String>() {