(flink-connector-aws) branch main updated: [hotfix][Connectors/DynamoDB] Fix flink-connector-aws-base version

[dannycranmer]

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(),