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
