You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by yi...@apache.org on 2022/03/25 07:03:27 UTC
[hudi] branch master updated: [HUDI-3711] Fix typo in MaxwellJsonKafkaSourcePostProcessor.Config#PRECOMBINE_FIELD_TYPE_PROP (#5096)
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 <wa...@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")