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/29 06:19:35 UTC
[flink] 05/05: [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 1b9fb2b6d07d54848e57d42333382a4553852491
Author: Timo Walther <tw...@apache.org>
AuthorDate: Tue May 28 16:21:30 2019 +0200
[hotfix][table-common] Fix invalid class to data type conversion
---
.../java/org/apache/flink/table/types/utils/ClassDataTypeConverter.java | 2 +-
.../java/org/apache/flink/table/types/ClassDataTypeConverterTest.java | 2 ++
2 files changed, 3 insertions(+), 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 a71c682..7001168 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(3));
+ addDefaultDataType(java.sql.Time.class, DataTypes.TIME(0));
addDefaultDataType(java.time.LocalTime.class, DataTypes.TIME(9));
addDefaultDataType(java.sql.Timestamp.class, DataTypes.TIMESTAMP(9));
addDefaultDataType(java.time.LocalDateTime.class, DataTypes.TIMESTAMP(9));
diff --git a/flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/ClassDataTypeConverterTest.java b/flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/ClassDataTypeConverterTest.java
index d889dec..46781cb 100644
--- a/flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/ClassDataTypeConverterTest.java
+++ b/flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/ClassDataTypeConverterTest.java
@@ -52,6 +52,8 @@ public class ClassDataTypeConverterTest {
{Long.class, DataTypes.BIGINT().nullable().bridgedTo(Long.class)},
+ {java.sql.Time.class, DataTypes.TIME(0).nullable().bridgedTo(java.sql.Time.class)},
+
{BigDecimal.class, null},
{