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

…pache#7103)
satishkotha · Dec 11, 2022 · 9a3d63f · 9a3d63f
1 parent 6751939
commit 9a3d63f
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
@@ -252,7 +252,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();
   }