diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/processor/maxwell/MaxwellJsonKafkaSourcePostProcessor.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/processor/maxwell/MaxwellJsonKafkaSourcePostProcessor.java index 9ca91893bec69..42e2556ea59fa 100644 --- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/processor/maxwell/MaxwellJsonKafkaSourcePostProcessor.java +++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/processor/maxwell/MaxwellJsonKafkaSourcePostProcessor.java @@ -91,9 +91,9 @@ public static class Config { public static final ConfigProperty PRECOMBINE_FIELD_TYPE_PROP = ConfigProperty .key("hoodie.deltastreamer.source.json.kafka.post.processor.maxwell.precombine.field.type") - .defaultValue("DATA_STRING") + .defaultValue(DATE_STRING.toString()) .withDocumentation("Data type of the preCombine field. could be NON_TIMESTAMP, DATE_STRING," - + "UNIX_TIMESTAMP or EPOCHMILLISECONDS. DATA_STRING by default "); + + "UNIX_TIMESTAMP or EPOCHMILLISECONDS. DATE_STRING by default "); public static final ConfigProperty PRECOMBINE_FIELD_FORMAT_PROP = ConfigProperty .key("hoodie.deltastreamer.source.json.kafka.post.processor.maxwell.precombine.field.format")