From 08f799888939c5a4fbeb026a5d2ae6ee23607ba4 Mon Sep 17 00:00:00 2001 From: sunxiaojian Date: Fri, 26 Jan 2024 11:23:18 +0800 Subject: [PATCH] fixed --- .../KafkaRecordDeserializationSchemaTest.java | 22 +++++++++++-------- 1 file changed, 13 insertions(+), 9 deletions(-) diff --git a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchemaTest.java b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchemaTest.java index 0951dd26c..ef1e0c3c7 100644 --- a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchemaTest.java +++ b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchemaTest.java @@ -22,7 +22,9 @@ import org.apache.flink.connector.testutils.formats.DummyInitializationContext; import org.apache.flink.connector.testutils.source.deserialization.TestingDeserializationContext; import org.apache.flink.formats.json.JsonDeserializationSchema; + import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonNode; + import org.apache.flink.streaming.util.serialization.JSONKeyValueDeserializationSchema; import org.apache.flink.util.Collector; @@ -48,7 +50,9 @@ import static org.assertj.core.api.Assertions.assertThat; -/** Unit tests for KafkaRecordDeserializationSchema. */ +/** + * Unit tests for KafkaRecordDeserializationSchema. + */ public class KafkaRecordDeserializationSchemaTest { private static final ObjectMapper OBJECT_MAPPER = JacksonMapperFactory.createObjectMapper(); @@ -87,17 +91,17 @@ public void testKafkaDeserializationSchemaWrapper() throws Exception { public void testKafkaValueDeserializationSchemaWrapper() throws Exception { final ConsumerRecord consumerRecord = getConsumerRecord(); KafkaRecordDeserializationSchema< - org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node - .ObjectNode> + org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node + .ObjectNode> schema = - KafkaRecordDeserializationSchema.valueOnly( - new JsonDeserializationSchema<>( - org.apache.flink.shaded.jackson2.com.fasterxml.jackson - .databind.node.ObjectNode.class)); + KafkaRecordDeserializationSchema.valueOnly( + new JsonDeserializationSchema<>( + org.apache.flink.shaded.jackson2.com.fasterxml.jackson + .databind.node.ObjectNode.class)); schema.open(new DummyInitializationContext()); SimpleCollector< - org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node - .ObjectNode> + org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node + .ObjectNode> collector = new SimpleCollector<>(); schema.deserialize(consumerRecord, collector);