[ https://issues.apache.org/jira/browse/FLINK-29938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637367#comment-17637367 ]
Danny Cranmer commented on FLINK-29938: --------------------------------------- Merged commit [{{91c4d86}}|https://github.com/apache/flink/commit/91c4d865eabad0f7f1b8c7426d87e86afa06d6f6] into apache:master > Add open() Method to AsyncSink ElementConverter > ----------------------------------------------- > > Key: FLINK-29938 > URL: https://issues.apache.org/jira/browse/FLINK-29938 > Project: Flink > Issue Type: Improvement > Components: Connectors / Common > Reporter: Danny Cranmer > Assignee: Danny Cranmer > Priority: Major > Labels: pull-request-available > Fix For: 1.17.0 > > > The {{ElementConverter}} is used to convert records to objects that a Sink > can deliver to a destination. In some sink implementations, the > {{ElementConverter}} needs to be serialized and sent to TM, DynamoDB is a > good example [1]. For DynamoDB we need to lazily instantiate some objects, > and an `open()` method would provide a clean hook for this. > [1] > https://github.com/apache/flink-connector-aws/blob/main/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDBEnhancedElementConverter.java#L57 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)