(flink-connector-aws) branch main updated: [FLINK-33194][Connectors/Kinesis] Remove dependency on Flink Shaded

[hong]

This is an automated email from the ASF dual-hosted git repository.

hong 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 c244bb3  [FLINK-33194][Connectors/Kinesis] Remove dependency on Flink 
Shaded
c244bb3 is described below

commit c244bb30240399f67557bbaf8e718d5eb158199d
Author: Jiabao Sun <jiabao....@xtransfer.cn>
AuthorDate: Fri Oct 20 00:11:19 2023 +0800

    [FLINK-33194][Connectors/Kinesis] Remove dependency on Flink Shaded
---
 .../connector/kinesis/source/split/KinesisShardSplit.java      | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplit.java
 
b/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplit.java
index b9d2488..2b75d7c 100644
--- 
a/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplit.java
+++ 
b/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplit.java
@@ -23,10 +23,10 @@ import org.apache.flink.api.connector.source.SourceSplit;
 import org.apache.flink.connector.base.source.reader.splitreader.SplitReader;
 import 
org.apache.flink.connector.kinesis.source.enumerator.KinesisStreamsSourceEnumerator;
 
-import 
org.apache.flink.shaded.curator5.org.apache.curator.shaded.com.google.common.base.Preconditions;
-
 import java.util.Objects;
 
+import static org.apache.flink.util.Preconditions.checkNotNull;
+
 /**
  * Contains information about the kinesis stream and shard. Serves as a 
communication mechanism
  * between the {@link KinesisStreamsSourceEnumerator} and the {@link 
SplitReader}. Information
@@ -41,9 +41,9 @@ public final class KinesisShardSplit implements SourceSplit {
     private final StartingPosition startingPosition;
 
     public KinesisShardSplit(String streamArn, String shardId, 
StartingPosition startingPosition) {
-        Preconditions.checkNotNull(streamArn, "streamArn cannot be null");
-        Preconditions.checkNotNull(shardId, "shardId cannot be null");
-        Preconditions.checkNotNull(startingPosition, "startingPosition cannot 
be null");
+        checkNotNull(streamArn, "streamArn cannot be null");
+        checkNotNull(shardId, "shardId cannot be null");
+        checkNotNull(startingPosition, "startingPosition cannot be null");
 
         this.streamArn = streamArn;
         this.shardId = shardId;