You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ho...@apache.org on 2023/10/27 09:16:11 UTC
(flink-connector-aws) branch main updated: [FLINK-33194][Connectors/Kinesis] Remove dependency on Flink Shaded
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 <ji...@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;