diff --git a/.editorconfig b/.editorconfig index 2e260749..6fcca23b 100644 --- a/.editorconfig +++ b/.editorconfig @@ -113,7 +113,7 @@ ij_java_doc_preserve_line_breaks = false # ij_java_generate_final_locals = false # ij_java_generate_final_parameters = false # ij_java_if_brace_force = never -ij_java_imports_layout = org.apache.flink.**,|,org.apache.flink.shaded.**,|,*,|,javax.**,|,java.**,|,scala.**,|,$* +ij_java_imports_layout = org.apache.flink.**,|,*,|,javax.**,|,java.**,|,scala.**,|,$* # ij_java_indent_case_from_switch = true # ij_java_insert_inner_class_imports = false # ij_java_insert_override_annotation = true diff --git a/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBaseITCase.java b/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBaseITCase.java index bd574d8f..613a1b33 100644 --- a/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBaseITCase.java +++ b/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBaseITCase.java @@ -28,8 +28,6 @@ import org.apache.flink.test.junit5.MiniClusterExtension; import org.apache.flink.util.TestLoggerExtension; -import org.apache.flink.shaded.guava30.com.google.common.collect.Lists; - import org.apache.http.HttpHost; import org.apache.http.auth.AuthScope; import org.apache.http.auth.UsernamePasswordCredentials; @@ -51,6 +49,7 @@ import javax.annotation.Nullable; import java.io.IOException; +import java.util.Arrays; import java.util.List; import java.util.UUID; import java.util.function.BiFunction; @@ -206,7 +205,7 @@ public Tuple2 map(Long value) throws Exception { private static List>>> elasticsearchEmitters() { - return Lists.newArrayList(TestEmitter::jsonEmitter, TestEmitter::smileEmitter); + return Arrays.asList(TestEmitter::jsonEmitter, TestEmitter::smileEmitter); } private static class FailingMapper implements MapFunction, CheckpointListener { diff --git a/pom.xml b/pom.xml index c6ecfa79..b56a1778 100644 --- a/pom.xml +++ b/pom.xml @@ -20,9 +20,9 @@ under the License. xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"> - io.github.zentol.flink + org.apache.flink flink-connector-parent - 1.0 + 1.0.0 4.0.0 @@ -51,7 +51,6 @@ under the License. 1.16.2 - 15.0 2.13.4.20221013 4.13.2 @@ -72,12 +71,6 @@ under the License. - - org.apache.flink - flink-shaded-force-shading - ${flink.shaded.version} - - diff --git a/tools/maven/checkstyle.xml b/tools/maven/checkstyle.xml index 2048fd18..17888ee8 100644 --- a/tools/maven/checkstyle.xml +++ b/tools/maven/checkstyle.xml @@ -195,7 +195,7 @@ This file is based on the checkstyle file of Apache Beam. + value="org.apache.flink,*,javax,java,scala"/> @@ -224,10 +224,6 @@ This file is based on the checkstyle file of Apache Beam. - - - -