From 15b2781b755f2f057c607ab483fd61c292809a76 Mon Sep 17 00:00:00 2001 From: dialalpha Date: Mon, 24 Apr 2023 13:07:50 -0400 Subject: [PATCH] [FLINK-28820] update Strings import --- .../flink/connector/pulsar/sink/writer/PulsarWriter.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java index f5bc543a..48a74b71 100644 --- a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java +++ b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java @@ -38,11 +38,10 @@ import org.apache.flink.connector.pulsar.sink.writer.topic.TopicProducerRegister; import org.apache.flink.util.FlinkRuntimeException; -import org.apache.flink.shaded.guava30.com.google.common.base.Strings; - import org.apache.pulsar.client.api.MessageId; import org.apache.pulsar.client.api.Schema; import org.apache.pulsar.client.api.TypedMessageBuilder; +import org.apache.pulsar.shade.com.google.common.base.Strings; import org.slf4j.Logger; import org.slf4j.LoggerFactory;