remove duplicate code

apache · Nov 1, 2022 · 2b979d5 · 2b979d5
1 parent 13fd5b9
commit 2b979d5
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();
   }