rename configOption

apache · Nov 1, 2022 · 30a0173 · 30a0173
1 parent 2b979d5
commit 30a0173
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java b/...flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
@@ -106,7 +106,7 @@ private FlinkOptions() {
           + "determined by Object.compareTo(..)");
 
   public static final ConfigOption<String> PAYLOAD_CLASS_NAME = ConfigOptions
-      .key("payload.class")
+      .key("write.payload.class")
       .stringType()
       .defaultValue(EventTimeAvroPayload.class.getName())
       .withFallbackKeys("write.payload.class")