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

…lways be consistent with input operator (#5049)

for chaining purpose

Co-authored-by: jerryyue <jerryyue@didiglobal.com>

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");
   }
 
   /**