commit 3b5d4ed7e11a6da02565354b01e804c20d4550e1
author big face cat <731030576@qq.com> Fri May 10 13:58:35 2024 +0800
committer GitHub <noreply@github.com> Fri May 10 13:58:35 2024 +0800
tree 5f6f8b3a58a6a5810ab75c3c1ce0a9515b7d2cfc
parent ca358a8ac56f009f8bb6ef00eaefcca6eb212baa

[fix] Fix the bug that the `DorisTypeMapper` datetime type will lose precision when converted to flink type (#379)

flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java
index bbabd80..55ab7b7 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java
@@ -125,7 +125,7 @@
                 return DataTypes.DATE();
             case DATETIME:
             case DATETIME_V2:
-                return DataTypes.TIMESTAMP(0);
+                return DataTypes.TIMESTAMP(scale);
             default:
                 throw new UnsupportedOperationException(
                         String.format(