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

Posted to commits@flink.apache.org by lz...@apache.org on 2020/03/25 05:10:03 UTC

[flink] branch master updated (1827e4d -> d38a010)

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 1827e4d  [FLINK-16170][elasticsearch] Fix SearchTemplateRequest ClassNotFoundException when using flink-sql-connector-elasticsearch7
     add 5642479  [FLINK-15579][table-planner-blink] UpsertStreamTableSink should work on batch mode
     add d38a010  [FLINK-15579][table-planner-blink] Fix UpsertStreamTableSink support and add tests

No new revisions were added by this update.

Summary of changes:
 .../java/io/jdbc/JDBCUpsertTableSinkITCase.java    | 40 ++++++++++
 .../plan/nodes/physical/batch/BatchExecSink.scala  | 21 ++++--
 .../nodes/physical/stream/StreamExecSink.scala     | 13 +---
 .../planner/plan/utils/UpdatingPlanChecker.scala   | 42 +++++++----
 .../runtime/batch/table/TableSinkITCase.scala      | 87 +++++++++++++++++++++-
 5 files changed, 168 insertions(+), 35 deletions(-)