From 6fe4d6e2f645db47b94f5c4d7743747308ef3d86 Mon Sep 17 00:00:00 2001 From: JerryYue-M <272614347@qq.com> Date: Fri, 18 Mar 2022 10:47:29 +0800 Subject: [PATCH] [HUDI-3598] Row Data to Hoodie Record Operator parallelism needs to always be consistent with input operator (#5049) for chaining purpose Co-authored-by: jerryyue --- .../src/main/java/org/apache/hudi/sink/utils/Pipelines.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java b/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java index ae8b4f21300a..0a5bb6cc3ef0 100644 --- a/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java +++ b/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java @@ -246,7 +246,8 @@ private static DataStream boundedBootstrap( * Transforms the row data to hoodie records. */ public static DataStream rowDataToHoodieRecord(Configuration conf, RowType rowType, DataStream dataStream) { - return dataStream.map(RowDataToHoodieFunctions.create(rowType, conf), TypeInformation.of(HoodieRecord.class)); + return dataStream.map(RowDataToHoodieFunctions.create(rowType, conf), TypeInformation.of(HoodieRecord.class)) + .setParallelism(dataStream.getParallelism()).name("row_data_to_hoodie_record"); } /**