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

Commit f658bb9

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

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/FlinkPulsarSource.java

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

6363
import org.apache.flink.shaded.guava18.com.google.common.collect.Sets;
6464

65-
import com.fasterxml.jackson.databind.ObjectMapper;
66-
import com.fasterxml.jackson.databind.ObjectWriter;
65+
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper;
66+
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectWriter;
6767
import lombok.extern.slf4j.Slf4j;
6868
import org.apache.pulsar.client.api.MessageId;
6969
import org.apache.pulsar.client.api.PulsarClientException;

0 commit comments

Comments
 (0)