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 41b6bfa [FLINK-15099][runtime] Add Operator Coordinators and Events add 74828e7 [FLINK-16046][es] Drop Elasticsearch 2 connector No new revisions were added by this update. Summary of changes: docs/dev/connectors/elasticsearch.md | 9 +- docs/dev/connectors/elasticsearch.zh.md | 9 +- .../flink-connector-elasticsearch-base/pom.xml | 39 +++- .../elasticsearch/ElasticsearchSinkBaseTest.java | 4 +- .../flink-connector-elasticsearch2/pom.xml | 229 --------------------- .../Elasticsearch2ApiCallBridge.java | 131 ------------ .../elasticsearch2/ElasticsearchSink.java | 111 ---------- .../elasticsearch2/ElasticsearchSinkFunction.java | 63 ------ .../OldNewElasticsearchSinkFunctionBridge.java | 47 ----- .../elasticsearch2/OldNewRequestIndexerBridge.java | 44 ---- .../connectors/elasticsearch2/RequestIndexer.java | 32 --- .../src/main/resources/META-INF/NOTICE | 83 -------- .../resources/META-INF/licenses/LICENSE.base64 | 26 --- .../META-INF/licenses/LICENSE.hdrhistogram | 125 ----------- .../resources/META-INF/licenses/LICENSE.jsr166e | 121 ----------- .../resources/META-INF/licenses/LICENSE.jsr166y | 26 --- .../main/resources/META-INF/licenses/LICENSE.jzlib | 26 --- .../resources/META-INF/licenses/LICENSE.webbit | 38 ---- .../EmbeddedElasticsearchNodeEnvironmentImpl.java | 69 ------- .../elasticsearch2/ElasticsearchSinkITCase.java | 112 ---------- .../src/test/resources/log4j-test.properties | 27 --- .../flink-connector-elasticsearch6/pom.xml | 6 + flink-connectors/pom.xml | 1 - .../flink-elasticsearch2-test/pom.xml | 77 ------- .../streaming/tests/Elasticsearch2SinkExample.java | 111 ---------- flink-end-to-end-tests/pom.xml | 1 - flink-end-to-end-tests/run-nightly-tests.sh | 1 - tools/travis/splits/split_misc.sh | 3 - tools/travis/splits/split_misc_hadoopfree.sh | 1 - tools/travis/stage.sh | 1 - tools/travis_controller.sh | 2 - 31 files changed, 50 insertions(+), 1525 deletions(-) delete mode 100644 flink-connectors/flink-connector-elasticsearch2/pom.xml delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/Elasticsearch2ApiCallBridge.java delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSinkFunction.java delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/OldNewElasticsearchSinkFunctionBridge.java delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/OldNewRequestIndexerBridge.java delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/RequestIndexer.java delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/main/resources/META-INF/NOTICE delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/main/resources/META-INF/licenses/LICENSE.base64 delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/main/resources/META-INF/licenses/LICENSE.hdrhistogram delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/main/resources/META-INF/licenses/LICENSE.jsr166e delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/main/resources/META-INF/licenses/LICENSE.jsr166y delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/main/resources/META-INF/licenses/LICENSE.jzlib delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/main/resources/META-INF/licenses/LICENSE.webbit delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/EmbeddedElasticsearchNodeEnvironmentImpl.java delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/test/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSinkITCase.java delete mode 100644 flink-connectors/flink-connector-elasticsearch2/src/test/resources/log4j-test.properties delete mode 100644 flink-end-to-end-tests/flink-elasticsearch2-test/pom.xml delete mode 100644 flink-end-to-end-tests/flink-elasticsearch2-test/src/main/java/org/apache/flink/streaming/tests/Elasticsearch2SinkExample.java