diff --git a/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java b/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java index 0f95c49af718d..b426cb1509621 100644 --- a/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java +++ b/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java @@ -255,13 +255,13 @@ private FlinkOptions() { + "Actual value obtained by invoking .toString(), default ''"); public static final ConfigOption URL_ENCODE_PARTITIONING = ConfigOptions - .key(KeyGeneratorOptions.URL_ENCODE_PARTITIONING_OPT_KEY) + .key(KeyGeneratorOptions.URL_ENCODE_PARTITIONING_OPT_KEY.key()) .booleanType() .defaultValue(false) .withDescription("Whether to encode the partition path url, default false"); public static final ConfigOption HIVE_STYLE_PARTITIONING = ConfigOptions - .key(KeyGeneratorOptions.HIVE_STYLE_PARTITIONING_OPT_KEY) + .key(KeyGeneratorOptions.HIVE_STYLE_PARTITIONING_OPT_KEY.key()) .booleanType() .defaultValue(false) .withDescription("Whether to use Hive style partitioning.\n"