This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 63aec82 [FLINK-20207][python] Improve the error message printed when
submitting the pyflink jobs via 'flink run'
add a5a6ab4 [FLINK-17159] Use testcontainers for Elasticsearch ITCases
No new revisions were added by this update.
Summary of changes:
.../elasticsearch/ElasticsearchSinkTestBase.java | 22 +++---
.../elasticsearch5/ElasticsearchSinkITCase.java | 18 +++++
.../flink-connector-elasticsearch6/pom.xml | 7 ++
.../EmbeddedElasticsearchNodeEnvironmentImpl.java | 79 ----------------------
.../table/Elasticsearch6DynamicSinkITCase.java | 37 +++++++---
.../elasticsearch6/ElasticsearchSinkITCase.java | 50 +++++++++-----
.../flink-connector-elasticsearch7/pom.xml | 7 ++
.../EmbeddedElasticsearchNodeEnvironmentImpl.java | 79 ----------------------
.../table/Elasticsearch7DynamicSinkITCase.java | 37 +++++++---
.../elasticsearch7/ElasticsearchSinkITCase.java | 41 +++++++++--
10 files changed, 165 insertions(+), 212 deletions(-)
delete mode 100644
flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/EmbeddedElasticsearchNodeEnvironmentImpl.java
delete mode 100644
flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/EmbeddedElasticsearchNodeEnvironmentImpl.java
