[ https://issues.apache.org/jira/browse/FLINK-17693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107299#comment-17107299 ]
Kurt Young commented on FLINK-17693: ------------------------------------ isn't TypeSerializer enough? > 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)