This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 789f3f5 [FLINK-24372][connectors/elasticsearch] Deprecate old (pre
FLIP-143) Elasticsearch connector
add 91d7d9e [FLINK-25189][connectors/elasticsearch] Bump Elasticsearch 7
to v7.15.2
add 56630de [FLINK-25189][connectors/elasticsearch] Bump Elasticsearch 6
to 6.8.20
add d8d3779 [FLINK-25189][docs][connectors/elasticsearch] Update
supported versions on Elasticsearch connector page
No new revisions were added by this update.
Summary of changes:
.../docs/connectors/datastream/elasticsearch.md | 4 +-
.../content/docs/connectors/table/elasticsearch.md | 2 +-
.../flink-connector-elasticsearch-base/pom.xml | 2 +-
.../sink/BulkProcessorBuilderFactory.java} | 20 ++--
.../elasticsearch/sink/BulkProcessorConfig.java | 9 +-
.../sink/BulkRequestConsumerFactory.java | 10 +-
.../elasticsearch/sink/ElasticsearchSink.java | 4 +
.../sink/ElasticsearchSinkBuilderBase.java | 21 ++--
.../elasticsearch/sink/ElasticsearchWriter.java | 56 ++---------
.../elasticsearch/ElasticsearchApiCallBridge.java | 10 ++
.../elasticsearch/ElasticsearchSinkBase.java | 5 +-
.../sink/ElasticsearchWriterITCase.java | 110 ++++++++++++++-------
.../elasticsearch/ElasticsearchSinkBaseTest.java | 10 +-
.../testutils/ElasticsearchResource.java | 2 +-
.../flink-connector-elasticsearch6/pom.xml | 5 +-
.../sink/Elasticsearch6SinkBuilder.java | 77 ++++++++++++---
.../Elasticsearch6ApiCallBridge.java | 6 ++
.../sink/Elasticsearch6SinkITCase.java | 3 +-
.../flink-connector-elasticsearch7/pom.xml | 18 +++-
.../sink/Elasticsearch7SinkBuilder.java | 80 ++++++++++++---
.../Elasticsearch7ApiCallBridge.java | 8 +-
.../sink/Elasticsearch7SinkITCase.java | 3 +-
.../flink-sql-connector-elasticsearch6/pom.xml | 4 +
.../src/main/resources/META-INF/NOTICE | 52 +++++-----
.../flink-sql-connector-elasticsearch7/pom.xml | 6 ++
.../src/main/resources/META-INF/NOTICE | 58 +++++------
flink-end-to-end-tests/run-nightly-tests.sh | 4 +-
.../test-scripts/test_quickstarts.sh | 2 +-
.../test-scripts/test_sql_client.sh | 4 +-
.../org/apache/flink/util/DockerImageVersions.java | 11 +--
30 files changed, 378 insertions(+), 228 deletions(-)
copy
flink-connectors/{flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/conversion/HiveObjectConversion.java
=>
flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorBuilderFactory.java}
(64%)
