You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by bi...@apache.org on 2024/01/16 06:15:30 UTC
(incubator-paimon) 03/07: [test] Fix unstable test of parallelism set error. (#2626)
This is an automated email from the ASF dual-hosted git repository.
biyan pushed a commit to branch release-0.6
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
commit e589ddd6ac9f509c77235d4138273b46aaeb98d9
Author: YeJunHao <41...@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>() {