From e5fda3ea0b245bfbf6a86576714c445e24eb6721 Mon Sep 17 00:00:00 2001 From: XiaoYou201 Date: Wed, 31 Jul 2024 20:56:33 +0800 Subject: [PATCH] [INLONG-10739][Sort] Fix format. --- .../sort/elasticsearch/table/RowElasticsearchSinkFunction.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/RowElasticsearchSinkFunction.java b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/RowElasticsearchSinkFunction.java index 7b12e9237cb..2467957b61f 100644 --- a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/RowElasticsearchSinkFunction.java +++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/RowElasticsearchSinkFunction.java @@ -17,7 +17,6 @@ package org.apache.inlong.sort.elasticsearch.table; -import org.apache.flink.api.common.serialization.RuntimeContextInitializationContextAdapters; import org.apache.inlong.sort.elasticsearch.ElasticsearchSinkFunction; import org.apache.inlong.sort.elasticsearch.RequestIndexer; @@ -31,8 +30,6 @@ import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.action.update.UpdateRequest; import org.elasticsearch.common.xcontent.XContentType; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; import javax.annotation.Nullable;