Skip to content
This repository was archived by the owner on Dec 14, 2022. It is now read-only.

Commit dd6b641

Browse files
Update pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarSinkBase.java
Co-authored-by: Jianyun Zhao <[email protected]>
1 parent ef03236 commit dd6b641

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarSinkBase.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,8 +40,8 @@
4040

4141
import org.apache.flink.shaded.guava18.com.google.common.collect.Maps;
4242

43-
import com.fasterxml.jackson.databind.ObjectMapper;
44-
import com.fasterxml.jackson.databind.ObjectWriter;
43+
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper;
44+
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectWriter;
4545
import lombok.extern.slf4j.Slf4j;
4646
import org.apache.pulsar.client.admin.PulsarAdmin;
4747
import org.apache.pulsar.client.api.MessageId;

0 commit comments

Comments
 (0)