[hudi] branch master updated: [MINOR] improve flink dummySink's parallelism (#6325)

[danny0405]

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

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 6b02877779 [MINOR] improve flink dummySink's parallelism (#6325)
6b02877779 is described below

commit 6b02877779efa5d800da8355a4ee1623be8fcf9b
Author: ForwardXu <forwardxu...@gmail.com>
AuthorDate: Mon Aug 8 17:28:15 2022 +0800

    [MINOR] improve flink dummySink's parallelism (#6325)
---
 .../src/main/java/org/apache/hudi/sink/utils/Pipelines.java           | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java
 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java
index f89bdb2606..0341d0af7f 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java
@@ -432,7 +432,9 @@ public class Pipelines {
   }
 
   public static DataStreamSink<Object> dummySink(DataStream<Object> 
dataStream) {
-    return dataStream.addSink(Pipelines.DummySink.INSTANCE).name("dummy");
+    return dataStream.addSink(Pipelines.DummySink.INSTANCE)
+        .setParallelism(1)
+        .name("dummy");
   }
 
   public static String opIdentifier(String operatorN, Configuration conf) {