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 <[email protected]> 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>() {
