From a8fe416827e4097e4965a929f9d9e9985fe36ed8 Mon Sep 17 00:00:00 2001
From: XuQianJin-Stars <forwardxu@apache.com>
Date: Mon, 8 Aug 2022 13:56:45 +0800
Subject: [PATCH] [MINOR] improve flink dummySink's parallelism

---
 .../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 f89bdb2606b01..0341d0af7f87d 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 static DataStreamSink<Object> clean(Configuration conf, DataStream<Object
   }
 
   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) {