You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by da...@apache.org on 2022/11/06 19:25:55 UTC
[flink-connector-aws] branch main updated: [FLINK-29909][Connectors/DynamoDB] Update package names to follow convention of other AWS connectors
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 3798aab [FLINK-29909][Connectors/DynamoDB] Update package names to follow convention of other AWS connectors
3798aab is described below
commit 3798aabfcc6f78645bf3d7255dfd6c336cd497f0
Author: Hong Liang Teoh <li...@amazon.com>
AuthorDate: Sat Nov 5 17:19:41 2022 +0000
[FLINK-29909][Connectors/DynamoDB] Update package names to follow convention of other AWS connectors
---
.../dynamodb/sink/DynamoDbConfigConstants.java | 2 +-
.../dynamodb/sink/DynamoDbSink.java | 2 +-
.../dynamodb/sink/DynamoDbSinkBuilder.java | 2 +-
.../dynamodb/sink/DynamoDbSinkException.java | 2 +-
.../dynamodb/sink/DynamoDbSinkWriter.java | 4 ++--
.../dynamodb/sink/DynamoDbWriteRequest.java | 2 +-
.../dynamodb/sink/DynamoDbWriteRequestType.java | 2 +-
.../dynamodb/sink/DynamoDbWriterStateSerializer.java | 4 ++--
.../dynamodb/sink/InvalidConfigurationException.java | 2 +-
.../dynamodb/sink/InvalidRequestException.java | 2 +-
.../dynamodb/util/DynamoDbSerializationUtil.java | 6 +++---
.../dynamodb/util/DynamoDbType.java | 2 +-
.../dynamodb/util/PrimaryKeyBuilder.java | 6 +++---
.../dynamodb/sink/DynamoDbSinkBuilderTest.java | 2 +-
.../dynamodb/sink/DynamoDbSinkITCase.java | 15 +++++++++------
.../dynamodb/sink/DynamoDbWriterStateSerializerTest.java | 2 +-
.../dynamodb/sink/TestDynamoDbElementConverter.java | 2 +-
.../dynamodb/sink/TestRequestMapper.java | 2 +-
.../dynamodb/sink/examples/SinkIntoDynamoDb.java | 8 ++++----
.../dynamodb/testutils/DynamoDBHelpers.java | 2 +-
.../dynamodb/testutils/DynamoDbContainer.java | 2 +-
.../connectors => connector}/dynamodb/testutils/Item.java | 2 +-
.../dynamodb/testutils/Items.java | 2 +-
.../dynamodb/util/DockerImageVersions.java | 2 +-
.../dynamodb/util/DynamoDbSerializationUtilTest.java | 6 +++---
.../dynamodb/util/PrimaryKeyBuilderTest.java | 4 ++--
26 files changed, 46 insertions(+), 43 deletions(-)
diff --git a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbConfigConstants.java b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbConfigConstants.java
similarity index 95%
rename from flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbConfigConstants.java
rename to flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbConfigConstants.java
index 03be741..c7eda9f 100644
--- a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbConfigConstants.java
+++ b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbConfigConstants.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.apache.flink.annotation.PublicEvolving;
diff --git a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSink.java b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSink.java
similarity index 99%
rename from flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSink.java
rename to flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSink.java
index c6b208b..e17d5f8 100644
--- a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSink.java
+++ b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSink.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.apache.flink.annotation.Internal;
import org.apache.flink.annotation.PublicEvolving;
diff --git a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkBuilder.java
similarity index 99%
rename from flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java
rename to flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkBuilder.java
index 6c955f0..6bfc025 100644
--- a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java
+++ b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkBuilder.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.connector.base.sink.AsyncSinkBaseBuilder;
diff --git a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkException.java b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkException.java
similarity index 96%
rename from flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkException.java
rename to flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkException.java
index 10a48af..0782395 100644
--- a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkException.java
+++ b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.apache.flink.annotation.PublicEvolving;
diff --git a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkWriter.java
similarity index 99%
rename from flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java
rename to flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkWriter.java
index bbbc201..d371727 100644
--- a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java
+++ b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkWriter.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.apache.flink.annotation.Internal;
import org.apache.flink.api.connector.sink2.Sink.InitContext;
@@ -27,9 +27,9 @@ import org.apache.flink.connector.base.sink.throwable.FatalExceptionClassifier;
import org.apache.flink.connector.base.sink.writer.AsyncSinkWriter;
import org.apache.flink.connector.base.sink.writer.BufferedRequestState;
import org.apache.flink.connector.base.sink.writer.ElementConverter;
+import org.apache.flink.connector.dynamodb.util.PrimaryKeyBuilder;
import org.apache.flink.metrics.Counter;
import org.apache.flink.metrics.groups.SinkWriterMetricGroup;
-import org.apache.flink.streaming.connectors.dynamodb.util.PrimaryKeyBuilder;
import org.apache.flink.util.CollectionUtil;
import org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableMap;
diff --git a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbWriteRequest.java b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequest.java
similarity index 98%
rename from flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbWriteRequest.java
rename to flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequest.java
index 4d60052..4fd340a 100644
--- a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbWriteRequest.java
+++ b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.util.Preconditions;
diff --git a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbWriteRequestType.java b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequestType.java
similarity index 97%
rename from flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbWriteRequestType.java
rename to flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequestType.java
index 0aea402..7a69e43 100644
--- a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbWriteRequestType.java
+++ b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequestType.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.apache.flink.annotation.PublicEvolving;
diff --git a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbWriterStateSerializer.java b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriterStateSerializer.java
similarity index 92%
rename from flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbWriterStateSerializer.java
rename to flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriterStateSerializer.java
index 039bf77..d06155c 100644
--- a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbWriterStateSerializer.java
+++ b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriterStateSerializer.java
@@ -16,11 +16,11 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.apache.flink.annotation.Internal;
import org.apache.flink.connector.base.sink.writer.AsyncSinkWriterStateSerializer;
-import org.apache.flink.streaming.connectors.dynamodb.util.DynamoDbSerializationUtil;
+import org.apache.flink.connector.dynamodb.util.DynamoDbSerializationUtil;
import java.io.DataInputStream;
import java.io.DataOutputStream;
diff --git a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/InvalidConfigurationException.java b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/InvalidConfigurationException.java
similarity index 94%
rename from flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/InvalidConfigurationException.java
rename to flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/InvalidConfigurationException.java
index f0bbae3..15c8c0e 100644
--- a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/InvalidConfigurationException.java
+++ b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/InvalidConfigurationException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.apache.flink.annotation.PublicEvolving;
diff --git a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/InvalidRequestException.java b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/InvalidRequestException.java
similarity index 94%
rename from flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/InvalidRequestException.java
rename to flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/InvalidRequestException.java
index a6ad194..104b93c 100644
--- a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/InvalidRequestException.java
+++ b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/InvalidRequestException.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.apache.flink.annotation.PublicEvolving;
diff --git a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/DynamoDbSerializationUtil.java b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/DynamoDbSerializationUtil.java
similarity index 97%
rename from flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/DynamoDbSerializationUtil.java
rename to flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/DynamoDbSerializationUtil.java
index c121d26..0e4a8eb 100644
--- a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/DynamoDbSerializationUtil.java
+++ b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/DynamoDbSerializationUtil.java
@@ -16,11 +16,11 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.util;
+package org.apache.flink.connector.dynamodb.util;
import org.apache.flink.annotation.Internal;
-import org.apache.flink.streaming.connectors.dynamodb.sink.DynamoDbWriteRequest;
-import org.apache.flink.streaming.connectors.dynamodb.sink.DynamoDbWriteRequestType;
+import org.apache.flink.connector.dynamodb.sink.DynamoDbWriteRequest;
+import org.apache.flink.connector.dynamodb.sink.DynamoDbWriteRequestType;
import software.amazon.awssdk.core.SdkBytes;
import software.amazon.awssdk.services.dynamodb.model.AttributeValue;
diff --git a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/DynamoDbType.java b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/DynamoDbType.java
similarity index 98%
rename from flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/DynamoDbType.java
rename to flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/DynamoDbType.java
index 31c66b4..ebc974d 100644
--- a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/DynamoDbType.java
+++ b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/DynamoDbType.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.util;
+package org.apache.flink.connector.dynamodb.util;
import org.apache.flink.annotation.Internal;
diff --git a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/PrimaryKeyBuilder.java b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/PrimaryKeyBuilder.java
similarity index 95%
rename from flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/PrimaryKeyBuilder.java
rename to flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/PrimaryKeyBuilder.java
index 239d993..d078dad 100644
--- a/flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/PrimaryKeyBuilder.java
+++ b/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/PrimaryKeyBuilder.java
@@ -16,11 +16,11 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.util;
+package org.apache.flink.connector.dynamodb.util;
import org.apache.flink.annotation.Internal;
-import org.apache.flink.streaming.connectors.dynamodb.sink.InvalidConfigurationException;
-import org.apache.flink.streaming.connectors.dynamodb.sink.InvalidRequestException;
+import org.apache.flink.connector.dynamodb.sink.InvalidConfigurationException;
+import org.apache.flink.connector.dynamodb.sink.InvalidRequestException;
import org.apache.flink.util.CollectionUtil;
import org.apache.commons.lang3.StringUtils;
diff --git a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilderTest.java b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkBuilderTest.java
similarity index 98%
rename from flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilderTest.java
rename to flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkBuilderTest.java
index 15941ac..a977abc 100644
--- a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilderTest.java
+++ b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkBuilderTest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.Test;
diff --git a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkITCase.java b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkITCase.java
similarity index 97%
rename from flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkITCase.java
rename to flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkITCase.java
index be27ab2..91353b2 100644
--- a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkITCase.java
+++ b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkITCase.java
@@ -16,20 +16,21 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.apache.flink.api.common.restartstrategy.RestartStrategies;
import org.apache.flink.connector.aws.config.AWSConfigConstants;
+import org.apache.flink.connector.dynamodb.testutils.DynamoDBHelpers;
+import org.apache.flink.connector.dynamodb.testutils.DynamoDbContainer;
+import org.apache.flink.connector.dynamodb.testutils.Item;
+import org.apache.flink.connector.dynamodb.testutils.Items;
+import org.apache.flink.connector.dynamodb.util.DockerImageVersions;
import org.apache.flink.runtime.client.JobExecutionException;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource;
import org.apache.flink.streaming.api.functions.source.datagen.RandomGenerator;
-import org.apache.flink.streaming.connectors.dynamodb.testutils.DynamoDBHelpers;
-import org.apache.flink.streaming.connectors.dynamodb.testutils.DynamoDbContainer;
-import org.apache.flink.streaming.connectors.dynamodb.testutils.Item;
-import org.apache.flink.streaming.connectors.dynamodb.testutils.Items;
-import org.apache.flink.streaming.connectors.dynamodb.util.DockerImageVersions;
+import org.apache.flink.test.junit5.MiniClusterExtension;
import org.apache.flink.util.StringUtils;
import org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableList;
@@ -37,6 +38,7 @@ import org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableList;
import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
import org.testcontainers.containers.Network;
import org.testcontainers.junit.jupiter.Container;
import org.testcontainers.junit.jupiter.Testcontainers;
@@ -60,6 +62,7 @@ import static org.apache.flink.connector.aws.config.AWSConfigConstants.TRUST_ALL
/** Integration test for {@link DynamoDbSink}. */
@Testcontainers
+@ExtendWith(MiniClusterExtension.class)
public class DynamoDbSinkITCase {
private static final String PARTITION_KEY = "key";
private static final String SORT_KEY = "sort_key";
diff --git a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbWriterStateSerializerTest.java b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriterStateSerializerTest.java
similarity index 97%
rename from flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbWriterStateSerializerTest.java
rename to flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriterStateSerializerTest.java
index 55e9102..b88000e 100644
--- a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbWriterStateSerializerTest.java
+++ b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriterStateSerializerTest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.apache.flink.connector.base.sink.writer.BufferedRequestState;
import org.apache.flink.connector.base.sink.writer.ElementConverter;
diff --git a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/TestDynamoDbElementConverter.java b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/TestDynamoDbElementConverter.java
similarity index 96%
rename from flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/TestDynamoDbElementConverter.java
rename to flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/TestDynamoDbElementConverter.java
index 8fd8d13..fec728d 100644
--- a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/TestDynamoDbElementConverter.java
+++ b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/TestDynamoDbElementConverter.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.apache.flink.api.connector.sink2.SinkWriter;
import org.apache.flink.connector.base.sink.writer.ElementConverter;
diff --git a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/TestRequestMapper.java b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/TestRequestMapper.java
similarity index 96%
rename from flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/TestRequestMapper.java
rename to flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/TestRequestMapper.java
index 445ac05..27e91fc 100644
--- a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/TestRequestMapper.java
+++ b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/TestRequestMapper.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink;
+package org.apache.flink.connector.dynamodb.sink;
import org.apache.flink.api.common.functions.RichMapFunction;
diff --git a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/examples/SinkIntoDynamoDb.java b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/examples/SinkIntoDynamoDb.java
similarity index 92%
rename from flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/examples/SinkIntoDynamoDb.java
rename to flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/examples/SinkIntoDynamoDb.java
index 53035fd..11726c9 100644
--- a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/examples/SinkIntoDynamoDb.java
+++ b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/sink/examples/SinkIntoDynamoDb.java
@@ -16,17 +16,17 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.sink.examples;
+package org.apache.flink.connector.dynamodb.sink.examples;
import org.apache.flink.api.common.functions.RichMapFunction;
import org.apache.flink.api.connector.sink2.SinkWriter;
import org.apache.flink.connector.aws.config.AWSConfigConstants;
import org.apache.flink.connector.base.sink.writer.ElementConverter;
+import org.apache.flink.connector.dynamodb.sink.DynamoDbSink;
+import org.apache.flink.connector.dynamodb.sink.DynamoDbWriteRequest;
+import org.apache.flink.connector.dynamodb.sink.DynamoDbWriteRequestType;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
-import org.apache.flink.streaming.connectors.dynamodb.sink.DynamoDbSink;
-import org.apache.flink.streaming.connectors.dynamodb.sink.DynamoDbWriteRequest;
-import org.apache.flink.streaming.connectors.dynamodb.sink.DynamoDbWriteRequestType;
import org.apache.commons.math3.random.RandomDataGenerator;
import software.amazon.awssdk.services.dynamodb.model.AttributeValue;
diff --git a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/testutils/DynamoDBHelpers.java b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/testutils/DynamoDBHelpers.java
similarity index 98%
rename from flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/testutils/DynamoDBHelpers.java
rename to flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/testutils/DynamoDBHelpers.java
index a4f9dc1..3124758 100644
--- a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/testutils/DynamoDBHelpers.java
+++ b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/testutils/DynamoDBHelpers.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.testutils;
+package org.apache.flink.connector.dynamodb.testutils;
import software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient;
import software.amazon.awssdk.services.dynamodb.model.AttributeDefinition;
diff --git a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/testutils/DynamoDbContainer.java b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/testutils/DynamoDbContainer.java
similarity index 98%
rename from flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/testutils/DynamoDbContainer.java
rename to flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/testutils/DynamoDbContainer.java
index e0ae78c..de091a7 100644
--- a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/testutils/DynamoDbContainer.java
+++ b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/testutils/DynamoDbContainer.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.testutils;
+package org.apache.flink.connector.dynamodb.testutils;
import org.apache.flink.connector.aws.config.AWSConfigConstants;
diff --git a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/testutils/Item.java b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/testutils/Item.java
similarity index 95%
rename from flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/testutils/Item.java
rename to flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/testutils/Item.java
index 27d148e..8ff0cb4 100644
--- a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/testutils/Item.java
+++ b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/testutils/Item.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.testutils;
+package org.apache.flink.connector.dynamodb.testutils;
import software.amazon.awssdk.services.dynamodb.model.AttributeValue;
diff --git a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/testutils/Items.java b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/testutils/Items.java
similarity index 95%
rename from flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/testutils/Items.java
rename to flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/testutils/Items.java
index fa2adbc..83356d2 100644
--- a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/testutils/Items.java
+++ b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/testutils/Items.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.testutils;
+package org.apache.flink.connector.dynamodb.testutils;
import software.amazon.awssdk.services.dynamodb.model.AttributeValue;
diff --git a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/util/DockerImageVersions.java b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/util/DockerImageVersions.java
similarity index 95%
rename from flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/util/DockerImageVersions.java
rename to flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/util/DockerImageVersions.java
index 6b7e29e..5fce066 100644
--- a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/util/DockerImageVersions.java
+++ b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/util/DockerImageVersions.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.util;
+package org.apache.flink.connector.dynamodb.util;
/**
* Utility class for defining the image names and versions of Docker containers used during the Java
diff --git a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/util/DynamoDbSerializationUtilTest.java b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/util/DynamoDbSerializationUtilTest.java
similarity index 96%
rename from flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/util/DynamoDbSerializationUtilTest.java
rename to flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/util/DynamoDbSerializationUtilTest.java
index 53434d8..68c1f0b 100644
--- a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/util/DynamoDbSerializationUtilTest.java
+++ b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/util/DynamoDbSerializationUtilTest.java
@@ -16,10 +16,10 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.util;
+package org.apache.flink.connector.dynamodb.util;
-import org.apache.flink.streaming.connectors.dynamodb.sink.DynamoDbWriteRequest;
-import org.apache.flink.streaming.connectors.dynamodb.sink.DynamoDbWriteRequestType;
+import org.apache.flink.connector.dynamodb.sink.DynamoDbWriteRequest;
+import org.apache.flink.connector.dynamodb.sink.DynamoDbWriteRequestType;
import org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableMap;
diff --git a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/util/PrimaryKeyBuilderTest.java b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/util/PrimaryKeyBuilderTest.java
similarity index 97%
rename from flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/util/PrimaryKeyBuilderTest.java
rename to flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/util/PrimaryKeyBuilderTest.java
index ff152f1..7a27708 100644
--- a/flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/util/PrimaryKeyBuilderTest.java
+++ b/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/util/PrimaryKeyBuilderTest.java
@@ -16,9 +16,9 @@
* limitations under the License.
*/
-package org.apache.flink.streaming.connectors.dynamodb.util;
+package org.apache.flink.connector.dynamodb.util;
-import org.apache.flink.streaming.connectors.dynamodb.sink.InvalidRequestException;
+import org.apache.flink.connector.dynamodb.sink.InvalidRequestException;
import org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableList;
import org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableMap;