[HUDI-5126] Delete duplicate configuration items PAYLOAD_CLASS_NAME (#…

…7103)
apache · Nov 3, 2022 · d36cc05 · d36cc05
1 parent cd314b8
commit d36cc05
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
@@ -253,7 +253,6 @@ public static HoodiePayloadConfig getPayloadConfig(Configuration conf) {
         .withPayloadClass(conf.getString(FlinkOptions.PAYLOAD_CLASS_NAME))
         .withPayloadOrderingField(conf.getString(FlinkOptions.PRECOMBINE_FIELD))
         .withPayloadEventTimeField(conf.getString(FlinkOptions.PRECOMBINE_FIELD))
-        .withPayloadClass(conf.getString(FlinkOptions.PAYLOAD_CLASS_NAME))
         .build();
   }