LakeShen created FLINK-13283:
--------------------------------
Summary: JDBCLookup Exception: Unsupported type: LocalDate
Key: FLINK-13283
URL: https://issues.apache.org/jira/browse/FLINK-13283
Project: Flink
Issue Type: Bug
Reporter: LakeShen
Hi , when I use Flink 1.9 JDBCTableSource,and I create TableSchema like this:
final TableSchema schema = TableSchema.builder()
.field("id", DataTypes.INT())
.field("create", DataTypes.DATE())
.field("update", DataTypes.DATE())
.field("name", DataTypes.STRING())
.field("age", DataTypes.INT())
.field("address", DataTypes.STRING())
.field("birthday",DataTypes.DATE())
.field("likethings", DataTypes.STRING())
.build();
I use JDBCTableSource.builder() to create JDBCTableSource, I run the program,
and there is a exception :
{color:red}java.lang.IllegalArgumentException: Unsupported type:
LocalDate{color}
I saw the src code , I find that in LegacyTypeInfoDataTypeConverter , DateType
convert to Types.LOCAL_DATE,but in JDBCTypeUtil class, the HashMap
TYPE_MAPPING doesn't have the key Types.LOCAL_DATE,so that throw the exception.
Does the JDBC dim table support the time data,Like Date?
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
