Skip to content

Commit 2606a82

Browse files
Jiabao-SunMartijnVisser
authored andcommitted
[FLINK-34193] Remove usage of Flink-Shaded Jackson and Snakeyaml in flink-connector-kafka
1 parent b8328ab commit 2606a82

File tree

2 files changed

+15
-9
lines changed

2 files changed

+15
-9
lines changed

flink-connector-kafka/pom.xml

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -171,6 +171,13 @@ under the License.
171171
<scope>test</scope>
172172
</dependency>
173173

174+
<dependency>
175+
<groupId>org.yaml</groupId>
176+
<artifactId>snakeyaml</artifactId>
177+
<version>1.31</version>
178+
<scope>test</scope>
179+
</dependency>
180+
174181
<dependency>
175182
<groupId>org.apache.flink</groupId>
176183
<artifactId>flink-test-utils</artifactId>

flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/YamlFileMetadataService.java

Lines changed: 8 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -23,20 +23,19 @@
2323
import org.apache.flink.connector.kafka.dynamic.metadata.KafkaMetadataService;
2424
import org.apache.flink.connector.kafka.dynamic.metadata.KafkaStream;
2525

26-
import org.apache.flink.shaded.jackson2.org.yaml.snakeyaml.DumperOptions;
27-
import org.apache.flink.shaded.jackson2.org.yaml.snakeyaml.TypeDescription;
28-
import org.apache.flink.shaded.jackson2.org.yaml.snakeyaml.Yaml;
29-
import org.apache.flink.shaded.jackson2.org.yaml.snakeyaml.constructor.Constructor;
30-
import org.apache.flink.shaded.jackson2.org.yaml.snakeyaml.nodes.Node;
31-
import org.apache.flink.shaded.jackson2.org.yaml.snakeyaml.nodes.SequenceNode;
32-
import org.apache.flink.shaded.jackson2.org.yaml.snakeyaml.nodes.Tag;
33-
import org.apache.flink.shaded.jackson2.org.yaml.snakeyaml.representer.Representer;
34-
3526
import com.google.common.base.MoreObjects;
3627
import com.google.common.collect.ImmutableMap;
3728
import org.apache.kafka.clients.CommonClientConfigs;
3829
import org.slf4j.Logger;
3930
import org.slf4j.LoggerFactory;
31+
import org.yaml.snakeyaml.DumperOptions;
32+
import org.yaml.snakeyaml.TypeDescription;
33+
import org.yaml.snakeyaml.Yaml;
34+
import org.yaml.snakeyaml.constructor.Constructor;
35+
import org.yaml.snakeyaml.nodes.Node;
36+
import org.yaml.snakeyaml.nodes.SequenceNode;
37+
import org.yaml.snakeyaml.nodes.Tag;
38+
import org.yaml.snakeyaml.representer.Representer;
4039

4140
import java.io.File;
4241
import java.io.FileWriter;

0 commit comments

Comments
 (0)