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

Commit 400f36d

Browse files
author
高章敏
committed
fix up import
1 parent 42c94cf commit 400f36d

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
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;

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)