[FLINK-29263] Remove Elasticsearch connector

DarkAssassinator · Sep 16, 2022 · d268ea1 · d268ea1
1 parent ef93bca
commit d268ea1
Show file tree

Hide file tree

Showing 168 changed files with 5 additions and 18,198 deletions.
diff --git a/docs/data/sql_connectors.yml b/docs/data/sql_connectors.yml
@@ -128,10 +128,10 @@ elastic:
     versions:
         - version: 6.x
           maven: flink-connector-elasticsearch6
-          sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch6/$version/flink-sql-connector-elasticsearch6-$version.jar
+          sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch6/1.16.0/flink-sql-connector-elasticsearch6-1.16.0.jar
         - version: 7.x and later versions
           maven: flink-connector-elasticsearch7
-          sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7/$version/flink-sql-connector-elasticsearch7-$version.jar
+          sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7/1.16.0/flink-sql-connector-elasticsearch7-1.16.0.jar
 
 hbase:
     name: HBase

diff --git a/flink-architecture-tests/flink-architecture-tests-production/pom.xml b/flink-architecture-tests/flink-architecture-tests-production/pom.xml
@@ -139,21 +139,6 @@ under the License.
 			<artifactId>flink-connector-cassandra_${scala.binary.version}</artifactId>
 		</dependency>
 
-		<dependency>
-			<groupId>org.apache.flink</groupId>
-			<artifactId>flink-connector-elasticsearch6</artifactId>
-		</dependency>
-
-		<dependency>
-			<groupId>org.apache.flink</groupId>
-			<artifactId>flink-connector-elasticsearch7</artifactId>
-		</dependency>
-
-		<dependency>
-			<groupId>org.apache.flink</groupId>
-			<artifactId>flink-connector-elasticsearch-base</artifactId>
-		</dependency>
-
 		<dependency>
 			<groupId>org.apache.flink</groupId>
 			<artifactId>flink-connector-files</artifactId>

diff --git a/flink-architecture-tests/pom.xml b/flink-architecture-tests/pom.xml
@@ -153,27 +153,6 @@ under the License.
 				<scope>test</scope>
 			</dependency>
 
-			<dependency>
-				<groupId>org.apache.flink</groupId>
-				<artifactId>flink-connector-elasticsearch6</artifactId>
-				<version>${project.version}</version>
-				<scope>test</scope>
-			</dependency>
-
-			<dependency>
-				<groupId>org.apache.flink</groupId>
-				<artifactId>flink-connector-elasticsearch7</artifactId>
-				<version>${project.version}</version>
-				<scope>test</scope>
-			</dependency>
-
-			<dependency>
-				<groupId>org.apache.flink</groupId>
-				<artifactId>flink-connector-elasticsearch-base</artifactId>
-				<version>${project.version}</version>
-				<scope>test</scope>
-			</dependency>
-
 			<dependency>
 				<groupId>org.apache.flink</groupId>
 				<artifactId>flink-connector-files</artifactId>

diff --git a/...ink-connector-elasticsearch-base/archunit-violations/dd583797-83e1-414c-a38d-330773978813 b/...ink-connector-elasticsearch-base/archunit-violations/dd583797-83e1-414c-a38d-330773978813
diff --git a/...ink-connector-elasticsearch-base/archunit-violations/de342dd1-c974-42c9-8f64-ef182ba8c56d b/...ink-connector-elasticsearch-base/archunit-violations/de342dd1-c974-42c9-8f64-ef182ba8c56d
diff --git a/flink-connectors/flink-connector-elasticsearch-base/archunit-violations/stored.rules b/flink-connectors/flink-connector-elasticsearch-base/archunit-violations/stored.rules
diff --git a/flink-connectors/flink-connector-elasticsearch-base/pom.xml b/flink-connectors/flink-connector-elasticsearch-base/pom.xml
diff --git a/.../main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorBuilderFactory.java b/.../main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorBuilderFactory.java
diff --git a/...base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorConfig.java b/...base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorConfig.java