[
https://issues.apache.org/jira/browse/FLINK-13283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885901#comment-16885901
]
Jingsong Lee commented on FLINK-13283:
--------------------------------------
Hi [~shenlang] Thanks to use new JDBC connectors, which runner did you use?
1.Flink runner not support java.time.LocalDate, you can use
DataTypes.DATE().bridgedTo(java.sql.Date.class) to use Java old Date class.
2.Blink runner can be supported in the same way. But for a better experience,
you're right to let JDBC connector support LocalDate.
> JDBCLookup Exception: Unsupported type: LocalDate
> -------------------------------------------------
>
> Key: FLINK-13283
> URL: https://issues.apache.org/jira/browse/FLINK-13283
> Project: Flink
> Issue Type: Bug
> Affects Versions: 1.9.0
> Reporter: LakeShen
> Priority: Major
> Fix For: 1.9.0
>
>
> 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? May it is bug for
> JDBCTableSource join.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
