You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2019/05/23 08:01:30 UTC
[flink] 05/06: [hotfix][table-common] Fix invalid class to data
type conversion
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3b13b60dc127d075b378d2f2e0a02b1b738c1245
Author: Timo Walther <tw...@apache.org>
AuthorDate: Tue May 21 14:44:20 2019 +0200
[hotfix][table-common] Fix invalid class to data type conversion
---
.../java/org/apache/flink/table/types/utils/ClassDataTypeConverter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/utils/ClassDataTypeConverter.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/utils/ClassDataTypeConverter.java
index 599c8b2..a71c682 100644
--- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/utils/ClassDataTypeConverter.java
+++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/utils/ClassDataTypeConverter.java
@@ -56,7 +56,7 @@ public final class ClassDataTypeConverter {
addDefaultDataType(double.class, DataTypes.DOUBLE());
addDefaultDataType(java.sql.Date.class, DataTypes.DATE());
addDefaultDataType(java.time.LocalDate.class, DataTypes.DATE());
- addDefaultDataType(java.sql.Time.class, DataTypes.TIME(9));
+ addDefaultDataType(java.sql.Time.class, DataTypes.TIME(3));
addDefaultDataType(java.time.LocalTime.class, DataTypes.TIME(9));
addDefaultDataType(java.sql.Timestamp.class, DataTypes.TIMESTAMP(9));
addDefaultDataType(java.time.LocalDateTime.class, DataTypes.TIMESTAMP(9));