[FLINK-13283] JDBC source/sink should respect the conversion class of DataType

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.9.0
• Fix Version/s: 1.10.0
• Component/s: Connectors / JDBC
• Labels: pull-request-available
• Assignee: Caizhi Weng
• Reporter: LakeShen
• Created: 16/Jul/19 07:22
• Updated: 30/Nov/22 20:41
• Resolved: 09/Dec/19 06:11

Description

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 :
java.lang.IllegalArgumentException: Unsupported type: LocalDate
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.

Issue Links

• links to: GitHub Pull Request #9236
• links to: PR #9236