You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/09/16 07:45:52 UTC
[flink] branch master updated (ef93bcace70 -> d268ea105cc)
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from ef93bcace70 [FLINK-27142][test] Rework SQL client E2E test
add d268ea105cc [FLINK-29263] Remove Elasticsearch connector
No new revisions were added by this update.
Summary of changes:
docs/data/sql_connectors.yml | 4 +-
.../flink-architecture-tests-production/pom.xml | 15 -
flink-architecture-tests/pom.xml | 21 -
.../dd583797-83e1-414c-a38d-330773978813 | 6 -
.../de342dd1-c974-42c9-8f64-ef182ba8c56d | 0
.../archunit-violations/stored.rules | 4 -
.../flink-connector-elasticsearch-base/pom.xml | 193 ------
.../sink/BulkProcessorBuilderFactory.java | 36 --
.../elasticsearch/sink/BulkProcessorConfig.java | 72 ---
.../sink/BulkRequestConsumerFactory.java | 35 --
.../elasticsearch/sink/ElasticsearchEmitter.java | 78 ---
.../elasticsearch/sink/ElasticsearchSink.java | 97 ---
.../sink/ElasticsearchSinkBuilderBase.java | 342 ----------
.../elasticsearch/sink/ElasticsearchWriter.java | 330 ----------
.../elasticsearch/sink/FlushBackoffType.java | 38 --
.../sink/MapElasticsearchEmitter.java | 81 ---
.../elasticsearch/sink/NetworkClientConfig.java | 78 ---
.../elasticsearch/sink/RequestIndexer.java | 56 --
.../table/AbstractTimeIndexGenerator.java | 41 --
.../table/ElasticsearchConfiguration.java | 158 -----
.../table/ElasticsearchConnectorOptions.java | 148 -----
.../table/ElasticsearchDynamicSink.java | 228 -------
.../table/ElasticsearchDynamicSinkFactoryBase.java | 257 --------
.../table/ElasticsearchSinkBuilderSupplier.java | 26 -
.../table/ElasticsearchValidationUtils.java | 92 ---
.../elasticsearch/table/IndexGenerator.java | 39 --
.../elasticsearch/table/IndexGeneratorBase.java | 52 --
.../elasticsearch/table/IndexGeneratorFactory.java | 317 ----------
.../elasticsearch/table/KeyExtractor.java | 97 ---
.../elasticsearch/table/LogicalTypeWithIndex.java | 31 -
.../table/RowElasticsearchEmitter.java | 129 ----
.../elasticsearch/table/StaticIndexGenerator.java | 35 --
.../elasticsearch/ActionRequestFailureHandler.java | 82 ---
.../elasticsearch/BufferingNoOpRequestIndexer.java | 75 ---
.../elasticsearch/ElasticsearchApiCallBridge.java | 122 ----
.../elasticsearch/ElasticsearchSinkBase.java | 525 ----------------
.../elasticsearch/ElasticsearchSinkFunction.java | 91 ---
.../connectors/elasticsearch/RequestIndexer.java | 84 ---
.../table/AbstractTimeIndexGenerator.java | 41 --
.../table/ElasticsearchConfiguration.java | 169 -----
.../table/ElasticsearchConnectorOptions.java | 165 -----
.../table/ElasticsearchValidationUtils.java | 94 ---
.../elasticsearch/table/IndexGenerator.java | 39 --
.../elasticsearch/table/IndexGeneratorBase.java | 52 --
.../elasticsearch/table/IndexGeneratorFactory.java | 314 ----------
.../elasticsearch/table/KeyExtractor.java | 130 ----
.../elasticsearch/table/RequestFactory.java | 54 --
.../table/RowElasticsearchSinkFunction.java | 143 -----
.../elasticsearch/table/StaticIndexGenerator.java | 35 --
.../elasticsearch/util/IgnoringFailureHandler.java | 38 --
.../elasticsearch/util/NoOpFailureHandler.java | 54 --
.../util/RetryRejectedExecutionFailureHandler.java | 59 --
.../architecture/TestCodeArchitectureTest.java | 43 --
.../connector/elasticsearch/ElasticsearchUtil.java | 92 ---
.../sink/ElasticsearchSinkBaseITCase.java | 221 -------
.../sink/ElasticsearchSinkBuilderBaseTest.java | 105 ----
.../sink/ElasticsearchWriterITCase.java | 422 -------------
.../elasticsearch/sink/TestClientBase.java | 72 ---
.../connector/elasticsearch/sink/TestEmitter.java | 78 ---
.../table/ElasticsearchDynamicSinkBaseITCase.java | 358 -----------
.../ElasticsearchDynamicSinkFactoryBaseTest.java | 256 --------
.../elasticsearch/table/IndexGeneratorTest.java | 370 -----------
.../elasticsearch/table/KeyExtractorTest.java | 148 -----
.../connector/elasticsearch/table/TestContext.java | 72 ---
.../elasticsearch/ElasticsearchSinkBaseTest.java | 690 ---------------------
.../elasticsearch/ElasticsearchSinkTestBase.java | 190 ------
.../EmbeddedElasticsearchNodeEnvironment.java | 54 --
.../elasticsearch/TestRequestIndexer.java | 78 ---
.../table/IndexGeneratorFactoryTest.java | 296 ---------
.../elasticsearch/table/KeyExtractorTest.java | 132 ----
.../elasticsearch/table/TestContext.java | 72 ---
.../testutils/ElasticsearchResource.java | 106 ----
.../testutils/SourceSinkDataTestKit.java | 156 -----
.../src/test/resources/archunit.properties | 31 -
.../src/test/resources/log4j2-test.properties | 28 -
.../25e52d29-fa7e-42fa-a571-b5c76235df52 | 0
.../db3972e4-f3a3-45b2-9643-27cba0cef09d | 12 -
.../archunit-violations/stored.rules | 4 -
.../flink-connector-elasticsearch6/pom.xml | 178 ------
.../sink/Elasticsearch6SinkBuilder.java | 131 ----
.../table/Elasticsearch6Configuration.java | 37 --
.../table/Elasticsearch6ConnectorOptions.java | 39 --
.../table/Elasticsearch6DynamicSinkFactory.java | 77 ---
.../table/Elasticsearch6Configuration.java | 79 ---
.../table/Elasticsearch6DynamicSink.java | 335 ----------
.../table/Elasticsearch6DynamicSinkFactory.java | 184 ------
.../Elasticsearch6ApiCallBridge.java | 148 -----
.../Elasticsearch6BulkProcessorIndexer.java | 85 ---
.../elasticsearch6/ElasticsearchSink.java | 269 --------
.../elasticsearch6/RestClientFactory.java | 42 --
.../org.apache.flink.table.factories.Factory | 16 -
.../architecture/TestCodeArchitectureTest.java | 57 --
.../sink/Elasticsearch6SinkBuilderTest.java | 37 --
.../sink/Elasticsearch6SinkITCase.java | 52 --
.../sink/Elasticsearch6TestClient.java | 36 --
.../Elasticsearch6DynamicSinkFactoryTest.java | 59 --
.../table/Elasticsearch6DynamicSinkITCase.java | 103 ---
.../Elasticsearch6DynamicSinkFactoryTest.java | 250 --------
.../table/Elasticsearch6DynamicSinkITCase.java | 403 ------------
.../table/Elasticsearch6DynamicSinkTest.java | 298 ---------
.../elasticsearch6/ElasticsearchSinkITCase.java | 133 ----
.../src/test/resources/archunit.properties | 31 -
.../src/test/resources/log4j2-test.properties | 28 -
.../1af7baaa-05dc-452a-9de7-653c8b3b324f | 0
.../e1f30f33-c61c-4707-8c78-a3a80479564e | 12 -
.../archunit-violations/stored.rules | 4 -
.../flink-connector-elasticsearch7/pom.xml | 175 ------
.../sink/Elasticsearch7SinkBuilder.java | 133 ----
.../table/Elasticsearch7DynamicSinkFactory.java | 33 -
.../table/Elasticsearch7Configuration.java | 70 ---
.../table/Elasticsearch7DynamicSink.java | 335 ----------
.../table/Elasticsearch7DynamicSinkFactory.java | 184 ------
.../Elasticsearch7ApiCallBridge.java | 152 -----
.../Elasticsearch7BulkProcessorIndexer.java | 85 ---
.../elasticsearch7/ElasticsearchSink.java | 269 --------
.../elasticsearch7/RestClientFactory.java | 42 --
.../org.apache.flink.table.factories.Factory | 16 -
.../architecture/TestCodeArchitectureTest.java | 57 --
.../sink/Elasticsearch7SinkBuilderTest.java | 37 --
.../sink/Elasticsearch7SinkITCase.java | 53 --
.../sink/Elasticsearch7TestClient.java | 37 --
.../Elasticsearch7DynamicSinkFactoryTest.java | 57 --
.../table/Elasticsearch7DynamicSinkITCase.java | 97 ---
.../Elasticsearch7DynamicSinkFactoryTest.java | 234 -------
.../table/Elasticsearch7DynamicSinkITCase.java | 377 -----------
.../table/Elasticsearch7DynamicSinkTest.java | 298 ---------
.../elasticsearch7/ElasticsearchSinkITCase.java | 133 ----
.../src/test/resources/archunit.properties | 31 -
.../src/test/resources/log4j2-test.properties | 28 -
.../flink-sql-connector-elasticsearch6/pom.xml | 153 -----
.../src/main/resources/META-INF/NOTICE | 47 --
.../flink-sql-connector-elasticsearch7/pom.xml | 162 -----
.../src/main/resources/META-INF/NOTICE | 47 --
flink-connectors/pom.xml | 5 -
.../pom.xml | 88 ---
.../flink/streaming/tests/ElasticsearchClient.java | 59 --
.../streaming/tests/ElasticsearchDataReader.java | 57 --
.../tests/ElasticsearchSinkE2ECaseBase.java | 101 ---
.../ElasticsearchSinkExternalContextBase.java | 123 ----
...lasticsearchSinkExternalContextFactoryBase.java | 59 --
.../streaming/tests/ElasticsearchTestEmitter.java | 51 --
.../org/apache/flink/streaming/tests/KeyValue.java | 92 ---
.../apache/flink/streaming/tests/QueryParams.java | 174 ------
.../streaming/tests/UpdateRequestFactory.java | 43 --
.../flink-end-to-end-tests-elasticsearch6/pom.xml | 143 -----
.../streaming/tests/Elasticsearch6Client.java | 149 -----
.../streaming/tests/UpdateRequest6Factory.java | 48 --
.../streaming/tests/Elasticsearch6SinkE2ECase.java | 62 --
.../tests/Elasticsearch6SinkExternalContext.java | 68 --
.../Elasticsearch6SinkExternalContextFactory.java | 48 --
.../src/test/resources/log4j2-test.properties | 34 -
.../flink-end-to-end-tests-elasticsearch7/pom.xml | 144 -----
.../streaming/tests/Elasticsearch7Client.java | 147 -----
.../streaming/tests/UpdateRequest7Factory.java | 46 --
.../streaming/tests/Elasticsearch7SinkE2ECase.java | 62 --
.../tests/Elasticsearch7SinkExternalContext.java | 68 --
.../Elasticsearch7SinkExternalContextFactory.java | 48 --
.../src/test/resources/log4j2-test.properties | 35 --
flink-end-to-end-tests/pom.xml | 3 -
flink-end-to-end-tests/test-scripts/common.sh | 3 -
.../test-scripts/elasticsearch-common.sh | 142 -----
flink-python/pom.xml | 3 +-
.../org/apache/flink/util/DockerImageVersions.java | 6 -
pom.xml | 2 -
tools/azure-pipelines/cache_docker_images.sh | 2 +-
tools/ci/compile.sh | 4 -
tools/ci/shade.sh | 26 -
tools/ci/stage.sh | 5 -
168 files changed, 5 insertions(+), 18198 deletions(-)
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/archunit-violations/dd583797-83e1-414c-a38d-330773978813
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/archunit-violations/de342dd1-c974-42c9-8f64-ef182ba8c56d
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/archunit-violations/stored.rules
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/pom.xml
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorBuilderFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorConfig.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkRequestConsumerFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchEmitter.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSink.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilderBase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriter.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/FlushBackoffType.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/MapElasticsearchEmitter.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/NetworkClientConfig.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/RequestIndexer.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/AbstractTimeIndexGenerator.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchConfiguration.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchConnectorOptions.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSink.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSinkFactoryBase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchSinkBuilderSupplier.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchValidationUtils.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGenerator.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorBase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/KeyExtractor.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/LogicalTypeWithIndex.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/RowElasticsearchEmitter.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/StaticIndexGenerator.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ActionRequestFailureHandler.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BufferingNoOpRequestIndexer.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkFunction.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/AbstractTimeIndexGenerator.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConfiguration.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConnectorOptions.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchValidationUtils.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGenerator.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorBase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/KeyExtractor.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RequestFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RowElasticsearchSinkFunction.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/StaticIndexGenerator.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/IgnoringFailureHandler.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/NoOpFailureHandler.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/RetryRejectedExecutionFailureHandler.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/ElasticsearchUtil.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBaseITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilderBaseTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriterITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/TestClientBase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/TestEmitter.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSinkBaseITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSinkFactoryBaseTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/table/KeyExtractorTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/table/TestContext.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBaseTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkTestBase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/EmbeddedElasticsearchNodeEnvironment.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/TestRequestIndexer.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/KeyExtractorTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/TestContext.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/testutils/ElasticsearchResource.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/testutils/SourceSinkDataTestKit.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/resources/archunit.properties
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/resources/log4j2-test.properties
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/archunit-violations/25e52d29-fa7e-42fa-a571-b5c76235df52
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/archunit-violations/db3972e4-f3a3-45b2-9643-27cba0cef09d
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/archunit-violations/stored.rules
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/pom.xml
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch6SinkBuilder.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch6Configuration.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch6ConnectorOptions.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch6DynamicSinkFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6Configuration.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6ApiCallBridge.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6BulkProcessorIndexer.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/RestClientFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch6SinkBuilderTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch6SinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch6TestClient.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch6DynamicSinkFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch6DynamicSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/resources/archunit.properties
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/resources/log4j2-test.properties
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/archunit-violations/1af7baaa-05dc-452a-9de7-653c8b3b324f
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/archunit-violations/e1f30f33-c61c-4707-8c78-a3a80479564e
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/archunit-violations/stored.rules
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/pom.xml
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch7SinkBuilder.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch7DynamicSinkFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7Configuration.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7ApiCallBridge.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7BulkProcessorIndexer.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/RestClientFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch7SinkBuilderTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch7SinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch7TestClient.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch7DynamicSinkFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch7DynamicSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/resources/archunit.properties
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/resources/log4j2-test.properties
delete mode 100644 flink-connectors/flink-sql-connector-elasticsearch6/pom.xml
delete mode 100644 flink-connectors/flink-sql-connector-elasticsearch6/src/main/resources/META-INF/NOTICE
delete mode 100644 flink-connectors/flink-sql-connector-elasticsearch7/pom.xml
delete mode 100644 flink-connectors/flink-sql-connector-elasticsearch7/src/main/resources/META-INF/NOTICE
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/pom.xml
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchClient.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchDataReader.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchSinkE2ECaseBase.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchSinkExternalContextBase.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchSinkExternalContextFactoryBase.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchTestEmitter.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/KeyValue.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/QueryParams.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/UpdateRequestFactory.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/pom.xml
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/main/java/org/apache/flink/streaming/tests/Elasticsearch6Client.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/main/java/org/apache/flink/streaming/tests/UpdateRequest6Factory.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/test/java/org/apache/flink/streaming/tests/Elasticsearch6SinkE2ECase.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/test/java/org/apache/flink/streaming/tests/Elasticsearch6SinkExternalContext.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/test/java/org/apache/flink/streaming/tests/Elasticsearch6SinkExternalContextFactory.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/test/resources/log4j2-test.properties
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/pom.xml
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/src/main/java/org/apache/flink/streaming/tests/Elasticsearch7Client.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/src/main/java/org/apache/flink/streaming/tests/UpdateRequest7Factory.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/src/test/java/org/apache/flink/streaming/tests/Elasticsearch7SinkE2ECase.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/src/test/java/org/apache/flink/streaming/tests/Elasticsearch7SinkExternalContext.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/src/test/java/org/apache/flink/streaming/tests/Elasticsearch7SinkExternalContextFactory.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/src/test/resources/log4j2-test.properties
delete mode 100644 flink-end-to-end-tests/test-scripts/elasticsearch-common.sh