[fix] Fix the bug that the DorisTypeMapper datetime type will lose …

…precision when converted to flink type (#379)
apache · May 10, 2024 · 3b5d4ed · 3b5d4ed
1 parent ca358a8
commit 3b5d4ed
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -125,7 +125,7 @@ public static DataType toFlinkType(
                 return DataTypes.DATE();
             case DATETIME:
             case DATETIME_V2:
-                return DataTypes.TIMESTAMP(0);
+                return DataTypes.TIMESTAMP(scale);
             default:
                 throw new UnsupportedOperationException(
                         String.format(