This is an automated email from the ASF dual-hosted git repository. dannycranmer pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-aws.git
The following commit(s) were added to refs/heads/main by this push: new b2e82b7 [hotfix][Connectors/DynamoDB] Fix flink-connector-aws-base version b2e82b7 is described below commit b2e82b787f21ba10eb3883cc9dcd815d0fa3f2f1 Author: Danny Cranmer <dannycran...@apache.org> AuthorDate: Tue Oct 31 14:11:22 2023 +0000 [hotfix][Connectors/DynamoDB] Fix flink-connector-aws-base version --- flink-connector-aws/flink-connector-dynamodb/pom.xml | 4 ++-- .../connector/dynamodb/sink/client/DynamoDbAsyncClientProvider.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/flink-connector-aws/flink-connector-dynamodb/pom.xml b/flink-connector-aws/flink-connector-dynamodb/pom.xml index 96df4d8..88ee389 100644 --- a/flink-connector-aws/flink-connector-dynamodb/pom.xml +++ b/flink-connector-aws/flink-connector-dynamodb/pom.xml @@ -57,7 +57,7 @@ under the License. <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-aws-base</artifactId> - <version>${flink.version}</version> + <version>${project.version}</version> </dependency> <!-- Flink Connector DynamoDB Dependencies --> @@ -98,7 +98,7 @@ under the License. <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-aws-base</artifactId> - <version>${flink.version}</version> + <version>${project.version}</version> <type>test-jar</type> <scope>test</scope> </dependency> diff --git a/flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/client/DynamoDbAsyncClientProvider.java b/flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/client/DynamoDbAsyncClientProvider.java index f72e304..b7c9717 100644 --- a/flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/client/DynamoDbAsyncClientProvider.java +++ b/flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/client/DynamoDbAsyncClientProvider.java @@ -20,7 +20,7 @@ package org.apache.flink.connector.dynamodb.sink.client; import org.apache.flink.annotation.Internal; import org.apache.flink.connector.aws.config.AWSConfigConstants; -import org.apache.flink.connector.aws.util.AWSAsyncSinkUtil; +import org.apache.flink.connector.aws.util.AWSClientUtil; import org.apache.flink.connector.aws.util.AWSGeneralUtil; import org.apache.flink.connector.dynamodb.sink.DynamoDbConfigConstants; @@ -65,7 +65,7 @@ public class DynamoDbAsyncClientProvider implements SdkClientProvider<DynamoDbAs Properties dynamoDbClientProperties, SdkAsyncHttpClient httpClient) { AWSGeneralUtil.validateAwsCredentials(dynamoDbClientProperties); - return AWSAsyncSinkUtil.createAwsAsyncClient( + return AWSClientUtil.createAwsAsyncClient( dynamoDbClientProperties, httpClient, DynamoDbAsyncClient.builder(),