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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

Shang Yuanchun (Jira)
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)