Checkstyle

apache · Nov 28, 2024 · 61c0d12 · 61c0d12
1 parent ad3ff0f
commit 61c0d12
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
diff --git a/...tor-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaConsumerFactory.java b/...tor-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaConsumerFactory.java
@@ -15,6 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.flink.connector.kafka.source;
 
 import org.apache.kafka.clients.consumer.KafkaConsumer;

diff --git a/...c/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java b/...c/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java
@@ -57,7 +57,6 @@
 import java.util.Properties;
 import java.util.Set;
 import java.util.StringJoiner;
-import java.util.function.Function;
 import java.util.function.Supplier;
 import java.util.stream.Collectors;