[ https://issues.apache.org/jira/browse/FLINK-17693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107375#comment-17107375 ]
Jark Wu commented on FLINK-17693: --------------------------------- Hi [~ykt836], we already introduced this method in {{DynamicTableSource}}. This issue is just expose the same API in {{DynamicTableSink}}. I think connector developers are advanced users and can distinguish them. > Add createTypeInformation to DynamicTableSink#Context > ----------------------------------------------------- > > Key: FLINK-17693 > URL: https://issues.apache.org/jira/browse/FLINK-17693 > Project: Flink > Issue Type: Sub-task > Components: Table SQL / API > Reporter: Jark Wu > Assignee: Jark Wu > Priority: Major > Labels: pull-request-available > Fix For: 1.11.0 > > > 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. -- This message was sent by Atlassian Jira (v8.3.4#803005)