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 551dfe4 [FLINK-24977][connectors/kafka] Replace ConfigOption lookup
in Map<String, String> object with proper lookup in Configuration object
add 789f3f5 [FLINK-24372][connectors/elasticsearch] Deprecate old (pre
FLIP-143) Elasticsearch connector
No new revisions were added by this update.
Summary of changes:
.../connectors/elasticsearch/ActionRequestFailureHandler.java | 3 +++
.../connectors/elasticsearch/ElasticsearchSinkFunction.java | 2 ++
.../flink/streaming/connectors/elasticsearch/RequestIndexer.java | 3 +++
.../elasticsearch/util/RetryRejectedExecutionFailureHandler.java | 3 +++
.../streaming/connectors/elasticsearch6/ElasticsearchSink.java | 6 ++++++
.../streaming/connectors/elasticsearch6/RestClientFactory.java | 3 +++
.../streaming/connectors/elasticsearch7/ElasticsearchSink.java | 6 ++++++
.../streaming/connectors/elasticsearch7/RestClientFactory.java | 3 +++
8 files changed, 29 insertions(+)
