[jira] [Updated] (FLINK-29938) Add open() Method to AsyncSink ElementConverter
[ https://issues.apache.org/jira/browse/FLINK-29938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29938: -- Fix Version/s: 1.17.0 > 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)
[jira] [Updated] (FLINK-29938) Add open() Method to AsyncSink ElementConverter
[ https://issues.apache.org/jira/browse/FLINK-29938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29938: --- Labels: pull-request-available (was: ) > 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 > > 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)
[jira] [Updated] (FLINK-29938) Add open() Method to AsyncSink ElementConverter
[ https://issues.apache.org/jira/browse/FLINK-29938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29938: -- Description: 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 was: 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 > 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 >Priority: Major > > 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)
[jira] [Updated] (FLINK-29938) Add open() Method to AsyncSink ElementConverter
[ https://issues.apache.org/jira/browse/FLINK-29938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29938: -- Description: 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 was: 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. For DynamoDB we need to lazily instantiate some objects, and an `open()` method would provide a clean hook for this. > 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 >Priority: Major > > 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)