This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new c7a8aa3 [fix]Fix BigDecimal precision missing (#347)
c7a8aa3 is described below
commit c7a8aa3f81fa0e4e2ab2ddb81b6aaddbe54a4e15
Author: wudongliang <[email protected]>
AuthorDate: Wed Mar 20 16:26:36 2024 +0800
[fix]Fix BigDecimal precision missing (#347)
---
.../flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
index c633264..b980908 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
@@ -20,6 +20,7 @@ package org.apache.doris.flink.sink.writer.serializer;
import org.apache.flink.annotation.VisibleForTesting;
import org.apache.flink.util.StringUtils;
+import com.fasterxml.jackson.core.JsonGenerator.Feature;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
@@ -84,9 +85,10 @@ public class JsonDebeziumSchemaSerializer implements
DorisRecordSerializer<Strin
this.pattern = pattern;
this.sourceTableName = sourceTableName;
// Prevent loss of decimal data precision
-
this.objectMapper.enable(DeserializationFeature.USE_BIG_DECIMAL_FOR_FLOATS);
JsonNodeFactory jsonNodeFactory =
JsonNodeFactory.withExactBigDecimals(true);
- this.objectMapper.setNodeFactory(jsonNodeFactory);
+
objectMapper.configure(DeserializationFeature.USE_BIG_DECIMAL_FOR_FLOATS, true);
+ objectMapper.configure(Feature.WRITE_BIGDECIMAL_AS_PLAIN, true);
+ objectMapper.setNodeFactory(jsonNodeFactory);
this.newSchemaChange = newSchemaChange;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
