[FLINK-13289] Blink-planner should setKeyFields to upsert table sink

• Type: Sub-task
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.9.0
• Fix Version/s: 1.9.0
• Component/s: Connectors / JDBC, Table SQL / Planner
• Labels: pull-request-available
• Assignee: Jingsong Lee
• Reporter: LakeShen
• Created: 16/Jul/19 13:51
• Updated: 01/Aug/19 10:57
• Resolved: 26/Jul/19 06:24

Description

Hi , in flink-jdbc connector module, I change the Flink planner to Blink planner to test all test case,because we want to use Blank planner in our program. When I test the JDBCUpsertTableSinkITCase class , the method testUpsert throw the exception:
java.lang.UnsupportedOperationException: JDBCUpsertTableSink can not support
I saw the src code,in Flink planner , the StreamPlanner set the JDBCUpsertTableSink' keyFields,
but in Blink planner , I didn't find anywhere to set JDBCUpsertTableSink' keyFields,so JDBCUpsertTableSink keyFields is null, when execute JDBCUpsertTableSink newFormat(),
it thrown the exception.

Issue Links

• links to: GitHub Pull Request #9195