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 604b128 [FLINK-25224][filesystem] Bump Hadoop version to 2.8.5
add 8560660 [FLINK-25141][connector/elasticsearch] Add sink parallelism
option
add f27c221 [FLINK-25141][docs] Add es sink parallelism option
No new revisions were added by this update.
Summary of changes:
.../docs/connectors/table/elasticsearch.md | 7 ++++++
.../content/docs/connectors/table/elasticsearch.md | 7 ++++++
.../table/ElasticsearchConfiguration.java | 5 ++++
.../table/ElasticsearchDynamicSink.java | 2 +-
.../table/ElasticsearchDynamicSinkFactoryBase.java | 4 ++-
.../connector/elasticsearch/ElasticsearchUtil.java | 28 +++++++++++++++++++++
.../table/ElasticsearchDynamicSinkBaseITCase.java | 29 ++--------------------
.../ElasticsearchDynamicSinkFactoryBaseTest.java | 21 ++++++++++++++++
8 files changed, 74 insertions(+), 29 deletions(-)
