This is an automated email from the ASF dual-hosted git repository. codope pushed a commit to branch release-0.12.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 58ca196b59000cf83fc97065267ea214dd438d4c Author: ForwardXu <[email protected]> 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) {
