This is an automated email from the ASF dual-hosted git repository.
healchow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new bdccc3a5e [INLONG-6537][Sort] Fix the decimal type loss of precision
during DDL synchronization (#6540)
bdccc3a5e is described below
commit bdccc3a5e29086e8bc240e72e58bef13f3290aac
Author: thesumery <[email protected]>
AuthorDate: Tue Nov 15 14:06:47 2022 +0800
[INLONG-6537][Sort] Fix the decimal type loss of precision during DDL
synchronization (#6540)
---
.../inlong/sort/base/format/JsonDynamicSchemaFormat.java | 11 +++++++----
1 file changed, 7 insertions(+), 4 deletions(-)
diff --git
a/inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java
b/inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java
index e6fc75528..cc70085fb 100644
---
a/inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java
+++
b/inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java
@@ -75,6 +75,9 @@ public abstract class JsonDynamicSchemaFormat extends
AbstractDynamicSchemaForma
*/
private static final Integer FIRST = 0;
+ private static final int DEFAULT_DECIMAL_PRECISION = 15;
+ private static final int DEFAULT_DECIMAL_SCALE = 5;
+
private static final Map<Integer, LogicalType>
SQL_TYPE_2_FLINK_TYPE_MAPPING =
ImmutableMap.<Integer, LogicalType>builder()
.put(java.sql.Types.CHAR, new CharType())
@@ -85,8 +88,8 @@ public abstract class JsonDynamicSchemaFormat extends
AbstractDynamicSchemaForma
.put(java.sql.Types.REAL, new FloatType())
.put(java.sql.Types.DOUBLE, new DoubleType())
.put(java.sql.Types.FLOAT, new FloatType())
- .put(java.sql.Types.DECIMAL, new DecimalType())
- .put(java.sql.Types.NUMERIC, new DecimalType())
+ .put(java.sql.Types.DECIMAL, new
DecimalType(DEFAULT_DECIMAL_PRECISION, DEFAULT_DECIMAL_SCALE))
+ .put(java.sql.Types.NUMERIC, new
DecimalType(DEFAULT_DECIMAL_PRECISION, DEFAULT_DECIMAL_SCALE))
.put(java.sql.Types.BIT, new BooleanType())
.put(java.sql.Types.TIME, new TimeType())
.put(java.sql.Types.TIMESTAMP_WITH_TIMEZONE, new
LocalZonedTimestampType())
@@ -109,8 +112,8 @@ public abstract class JsonDynamicSchemaFormat extends
AbstractDynamicSchemaForma
.put(java.sql.Types.REAL, new FloatType())
.put(java.sql.Types.DOUBLE, new DoubleType())
.put(java.sql.Types.FLOAT, new FloatType())
- .put(java.sql.Types.DECIMAL, new DecimalType())
- .put(java.sql.Types.NUMERIC, new DecimalType())
+ .put(java.sql.Types.DECIMAL, new
DecimalType(DEFAULT_DECIMAL_PRECISION, DEFAULT_DECIMAL_SCALE))
+ .put(java.sql.Types.NUMERIC, new
DecimalType(DEFAULT_DECIMAL_PRECISION, DEFAULT_DECIMAL_SCALE))
.put(java.sql.Types.BIT, new BooleanType())
.put(java.sql.Types.TIME, new VarCharType())
.put(java.sql.Types.TIMESTAMP_WITH_TIMEZONE, new
LocalZonedTimestampType())
