From f20c9867d7c347c43b22f70270aefb9b7f658461 Mon Sep 17 00:00:00 2001 From: wangxianghu Date: Fri, 25 Mar 2022 11:02:54 +0400 Subject: [PATCH] [HUDI-3711] Fix typo in MaxwellJsonKafkaSourcePostProcessor.Config#PRECOMBINE_FIELD_TYPE_PROP (#5096) --- .../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 9ca91893b..42e2556ea 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 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")