This is an automated email from the ASF dual-hosted git repository.
yihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new f20c986 [HUDI-3711] Fix typo in
MaxwellJsonKafkaSourcePostProcessor.Config#PRECOMBINE_FIELD_TYPE_PROP (#5096)
f20c986 is described below
commit f20c9867d7c347c43b22f70270aefb9b7f658461
Author: wangxianghu <wangxian...@apache.org>
AuthorDate: Fri Mar 25 11:02:54 2022 +0400
[HUDI-3711] Fix typo in
MaxwellJsonKafkaSourcePostProcessor.Config#PRECOMBINE_FIELD_TYPE_PROP (#5096)
---
.../processor/maxwell/MaxwellJsonKafkaSourcePostProcessor.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 9ca9189..42e2556 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 class MaxwellJsonKafkaSourcePostProcessor extends
JsonKafkaSourcePostProc
public static final ConfigProperty<String> 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<String> PRECOMBINE_FIELD_FORMAT_PROP =
ConfigProperty
.key("hoodie.deltastreamer.source.json.kafka.post.processor.maxwell.precombine.field.format")
