spotless apply

Author: klam-shop

flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java

@@ -192,9 +192,7 @@ private String getTargetTopic(RowData element) {
     }
 
     private boolean cachedTopicPatternMatch(String topic) {
-        return topicPatternMatches.computeIfAbsent(
-                topic,
-                t -> topicPattern.matcher(t).matches());
+        return topicPatternMatches.computeIfAbsent(topic, t -> topicPattern.matcher(t).matches());
     }
 
     private Integer extractPartition(
@@ -205,11 +203,7 @@ private Integer extractPartition(
             int[] partitions) {
         if (partitioner != null) {
             return partitioner.partition(
-                    consumedRow,
-                    keySerialized,
-                    valueSerialized,
-                    targetTopic,
-                    partitions);
+                    consumedRow, keySerialized, valueSerialized, targetTopic, partitions);
         }
         return null;
     }

flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchemaTest.java

@@ -59,7 +59,8 @@ public void testInvalidTopicMetadata(
     private static Stream<Arguments> provideTopicMetadataTestParameters() {
         String topic1 = "topic1";
         return Stream.of(
-                Arguments.of(Collections.singletonList(SINGLE_TOPIC), null, SINGLE_TOPIC, SINGLE_TOPIC),
+                Arguments.of(
+                        Collections.singletonList(SINGLE_TOPIC), null, SINGLE_TOPIC, SINGLE_TOPIC),
                 Arguments.of(Collections.singletonList(SINGLE_TOPIC), null, topic1, SINGLE_TOPIC),
                 Arguments.of(Collections.singletonList(SINGLE_TOPIC), null, null, SINGLE_TOPIC),
                 Arguments.of(MULTIPLE_TOPICS, null, topic1, topic1),

flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java

@@ -235,7 +235,9 @@ public void testKafkaSourceSinkWithTopicList() throws Exception {
         List<Row> results = collectAllRows(tEnv.sqlQuery("SELECT * from kafka"));
 
         assertThat(results)
-                .containsExactly(Row.of(topic1, 1, 1102, "behavior 1"), Row.of(topic2, 2, 1103, "behavior 2"));
+                .containsExactly(
+                        Row.of(topic1, 1, 1102, "behavior 1"),
+                        Row.of(topic2, 2, 1103, "behavior 2"));
 
         // ------------- cleanup -------------------
 
@@ -290,7 +292,9 @@ public void testKafkaSourceSinkWithTopicPattern() throws Exception {
         List<Row> results = collectAllRows(tEnv.sqlQuery("SELECT * from kafka"));
 
         assertThat(results)
-                .containsExactly(Row.of(topic1, 1, 1102, "behavior 1"), Row.of(topic2, 2, 1103, "behavior 2"));
+                .containsExactly(
+                        Row.of(topic1, 1, 1102, "behavior 1"),
+                        Row.of(topic2, 2, 1103, "behavior 2"));
 
         // ------------- cleanup -------------------