This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch main
in repository
https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git
from 19dfe58 [hotfix] Remove usage of deprecated
RestHighLevelClient#bulkAsync
new 86decf0 [hotfix][build] Rat ignores japicmp output
new 6823b86 [hotfix][ci] Upgrade Maven to 3.8.6
new afd3784 [hotfix][build] Fix flink-annotations version
new a9328df [FLINK-28410][tests] Sync E2E tests
new b793850 [hotfix][build] Remove unnecessary surefire config
new 06e38d1 [hotfix][ci] Hide Maven download transfer
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/ci.yml | 17 +-
.../pom.xml | 77 +++++++++
.../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/test/parameters/ParameterProperty.java | 58 +++++++
.../org/apache/flink/tests/util/TestUtils.java | 85 ++++++++++
.../pom.xml | 120 ++++++++++++++
.../streaming/tests/Elasticsearch6Client.java | 149 ++++++++++++++++++
.../streaming/tests/UpdateRequest6Factory.java | 48 ++++++
.../streaming/tests/Elasticsearch6SinkE2ECase.java | 60 +++++++
.../tests/Elasticsearch6SinkExternalContext.java | 68 ++++++++
.../Elasticsearch6SinkExternalContextFactory.java | 48 ++++++
.../src/test/resources/log4j2-test.properties | 24 +--
.../pom.xml | 121 ++++++++++++++
.../streaming/tests/Elasticsearch7Client.java | 147 +++++++++++++++++
.../streaming/tests/UpdateRequest7Factory.java | 46 ++++++
.../streaming/tests/Elasticsearch7SinkE2ECase.java | 60 +++++++
.../tests/Elasticsearch7SinkExternalContext.java | 68 ++++++++
.../Elasticsearch7SinkExternalContextFactory.java | 48 ++++++
.../src/test/resources/log4j2-test.properties | 23 ++-
flink-connector-elasticsearch-e2e-tests/pom.xml | 128 +++++++++++++++
pom.xml | 11 +-
29 files changed, 2137 insertions(+), 28 deletions(-)
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/pom.xml
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/streaming/tests/ElasticsearchClient.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/streaming/tests/ElasticsearchDataReader.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/streaming/tests/ElasticsearchSinkE2ECaseBase.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/streaming/tests/ElasticsearchSinkExternalContextBase.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/streaming/tests/ElasticsearchSinkExternalContextFactoryBase.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/streaming/tests/ElasticsearchTestEmitter.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/streaming/tests/KeyValue.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/streaming/tests/QueryParams.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/streaming/tests/UpdateRequestFactory.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/test/parameters/ParameterProperty.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch-e2e-tests-common/src/main/java/org/apache/flink/tests/util/TestUtils.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch6-e2e-tests/pom.xml
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch6-e2e-tests/src/main/java/org/apache/flink/streaming/tests/Elasticsearch6Client.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch6-e2e-tests/src/main/java/org/apache/flink/streaming/tests/UpdateRequest6Factory.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch6-e2e-tests/src/test/java/org/apache/flink/streaming/tests/Elasticsearch6SinkE2ECase.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch6-e2e-tests/src/test/java/org/apache/flink/streaming/tests/Elasticsearch6SinkExternalContext.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch6-e2e-tests/src/test/java/org/apache/flink/streaming/tests/Elasticsearch6SinkExternalContextFactory.java
copy {flink-connector-elasticsearch6 =>
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch6-e2e-tests}/src/test/resources/log4j2-test.properties
(60%)
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch7-e2e-tests/pom.xml
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch7-e2e-tests/src/main/java/org/apache/flink/streaming/tests/Elasticsearch7Client.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch7-e2e-tests/src/main/java/org/apache/flink/streaming/tests/UpdateRequest7Factory.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch7-e2e-tests/src/test/java/org/apache/flink/streaming/tests/Elasticsearch7SinkE2ECase.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch7-e2e-tests/src/test/java/org/apache/flink/streaming/tests/Elasticsearch7SinkExternalContext.java
create mode 100644
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch7-e2e-tests/src/test/java/org/apache/flink/streaming/tests/Elasticsearch7SinkExternalContextFactory.java
copy {flink-connector-elasticsearch6 =>
flink-connector-elasticsearch-e2e-tests/flink-connector-elasticsearch7-e2e-tests}/src/test/resources/log4j2-test.properties
(60%)
create mode 100644 flink-connector-elasticsearch-e2e-tests/pom.xml
