You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gu...@apache.org on 2023/02/16 09:33:40 UTC
[flink-connector-pulsar] 03/05: [FLINK-28959][Stream] Fix the wrong use of Guava's Preconditions.
This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-pulsar.git
commit 53d1468c609561575d4bfeffa62031ca8f4ee163
Author: Yufan Sheng <yu...@streamnative.io>
AuthorDate: Thu Feb 16 14:10:19 2023 +0800
[FLINK-28959][Stream] Fix the wrong use of Guava's Preconditions.
---
.../flink/connector/pulsar/sink/writer/router/KeyHashTopicRouter.java | 2 +-
.../connector/pulsar/sink/writer/router/RoundRobinTopicRouter.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/KeyHashTopicRouter.java b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/KeyHashTopicRouter.java
index 0405bb3..a98a897 100644
--- a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/KeyHashTopicRouter.java
+++ b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/KeyHashTopicRouter.java
@@ -30,7 +30,7 @@ import org.apache.pulsar.client.impl.Hash;
import java.util.List;
import java.util.concurrent.ThreadLocalRandom;
-import static org.apache.flink.shaded.guava30.com.google.common.base.Preconditions.checkArgument;
+import static org.apache.flink.util.Preconditions.checkArgument;
import static org.apache.pulsar.client.util.MathUtils.signSafeMod;
/**
diff --git a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/RoundRobinTopicRouter.java b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/RoundRobinTopicRouter.java
index 4bb27e9..eb04a58 100644
--- a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/RoundRobinTopicRouter.java
+++ b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/RoundRobinTopicRouter.java
@@ -27,7 +27,7 @@ import org.apache.flink.util.Preconditions;
import java.util.List;
import java.util.concurrent.atomic.AtomicLong;
-import static org.apache.flink.shaded.guava30.com.google.common.base.Preconditions.checkArgument;
+import static org.apache.flink.util.Preconditions.checkArgument;
/**
* If you choose the {@link TopicRoutingMode#ROUND_ROBIN} policy, we would use this implementation.