commit ead6bc4494c8b4d0580e6f221e9bdee0b0d2a714
author Chesnay Schepler <chesnay@apache.org> Tue Oct 10 13:17:24 2023 +0200
committer Chesnay Schepler <chesnay@apache.org> Tue Oct 10 13:17:24 2023 +0200
tree 502560e3dea6b30e7e590c4208935d562e09271d
parent e5426a8a5337882fa0f7524ba81d9bc8eae4ddd9

make me pretty

flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchemaTest.java

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 a2a7a35..28560cf 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
@@ -96,13 +96,14 @@
                 collector = new SimpleCollector<>();
         schema.deserialize(consumerRecord, collector);
 
-        assertThat(collector.list).hasSize(1);
-        org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode
-                deserializedValue = collector.list.get(0);
-
-        assertThat(deserializedValue.get("word").asText()).isEqualTo("world");
-        assertThat(deserializedValue.get("key")).isNull();
-        assertThat(deserializedValue.get("metadata")).isNull();
+        assertThat(collector.list)
+                .hasSize(1)
+                .allSatisfy(
+                        deserializedValue -> {
+                            assertThat(deserializedValue.get("word").asText()).isEqualTo("world");
+                            assertThat(deserializedValue.get("key")).isNull();
+                            assertThat(deserializedValue.get("metadata")).isNull();
+                        });
     }
 
     @Test