[HUDI-3598] Row Data to Hoodie Record Operator parallelism needs to a…

…lways be consistent with input operator for chaining purpose
apache · Mar 16, 2022 · 8d9fe30 · 8d9fe30
1 parent 034adda
commit 8d9fe30
Showing 1 changed file with 2 additions and 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
@@ -246,7 +246,8 @@ private static DataStream<HoodieRecord> boundedBootstrap(
    * Transforms the row data to hoodie records.
    */
   public static DataStream<HoodieRecord> rowDataToHoodieRecord(Configuration conf, RowType rowType, DataStream<RowData> 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");
   }
 
   /**