[FLINK-17693] Add createTypeInformation to DynamicTableSink#Context

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Jark Wu
• Reporter: Jark Wu
• Created: 14/May/20 13:28
• Updated: 15/May/20 07:31
• Resolved: 15/May/20 07:31

Description

Currently, we have createTypeInformation on DynamicTableSource#Context, but not on DynamicTableSink#Context.
In some sink connectors, we need to buffer the RowData and flush at some interval. So we need to copy the RowData if object reuse is enabled, then the internal TypeInformation is needed to get the RowData TypeSerializer#copy.

Issue Links

• links to: GitHub Pull Request #12154