[flink] 05/06: [hotfix][table-common] Fix invalid class to data type conversion

[twalthr]

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 <twal...@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));