diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
index 55abeaaa56c2..dccb5d1360ad 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
+++ b/hudi-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")