You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by fp...@apache.org on 2022/01/10 09:47:35 UTC

[flink] branch master updated (604b128 -> f27c221)

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(-)