You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "LakeShen (JIRA)" <ji...@apache.org> on 2019/07/16 07:23:00 UTC

[jira] [Created] (FLINK-13283) JDBCLookup Exception: Unsupported type: LocalDate

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)