fixed

apache · Jan 26, 2024 · 08f7998 · 08f7998
1 parent cf522ef
commit 08f7998
Showing 1 changed file with 13 additions and 9 deletions.
diff --git a/...link/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchemaTest.java b/...link/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<byte[], byte[]> 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);