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 bbabd8035..55ab7b73e 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 @@ 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(