(doris-flink-connector) branch master updated: [fix] Fix the bug that the `DorisTypeMapper` datetime type will lose precision when converted to flink type (#379)

[diwu]

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 3b5d4ed  [fix] Fix the bug that the `DorisTypeMapper` datetime type 
will lose precision when converted to flink type (#379)
3b5d4ed is described below

commit 3b5d4ed7e11a6da02565354b01e804c20d4550e1
Author: big face cat <731030...@qq.com>
AuthorDate: Fri May 10 13:58:35 2024 +0800

    [fix] Fix the bug that the `DorisTypeMapper` datetime type will lose 
precision when converted to flink type (#379)
---
 .../src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java   | 2 +-
 1 file changed, 1 insertion(+), 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
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 @@ public class DorisTypeMapper {
                 return DataTypes.DATE();
             case DATETIME:
             case DATETIME_V2:
-                return DataTypes.TIMESTAMP(0);
+                return DataTypes.TIMESTAMP(scale);
             default:
                 throw new UnsupportedOperationException(
                         String.format(


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org