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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
