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

Commit

Permalink
Update pulsar-flink-connector/src/main/java/org/apache/flink/streamin…
Browse files Browse the repository at this point in the history 
…g/connectors/pulsar/FlinkPulsarSource.java

Co-authored-by: Jianyun Zhao <[email protected]>
  • Loading branch information
@gaozhangmin @jianyun8023
gaozhangmin and jianyun8023 authored Nov 5, 2021
1 parent dd6b641 commit f658bb9
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions ...nnector/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarSource.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -62,8 +62,8 @@

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

import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.ObjectWriter;
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectWriter;
import lombok.extern.slf4j.Slf4j;
import org.apache.pulsar.client.api.MessageId;
import org.apache.pulsar.client.api.PulsarClientException;
Expand Down

0 comments on commit f658bb9

Please sign in to comment.