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

Posted to commits@flink.apache.org by yu...@apache.org on 2023/05/19 07:23:44 UTC

[flink] branch master updated (522fac5c1d0 -> 6695d84dbb7)

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

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


    from 522fac5c1d0 [FLINK-29542][docs] Fix typos in unload.md
     add 6695d84dbb7 [FLINK-32001][table] Row-level update should support returning partial columns (#22525)

No new revisions were added by this update.

Summary of changes:
 .../src/test/resources/sql/delete.q                |   2 +-
 .../table/planner/connectors/DynamicSinkUtils.java | 134 +++++++++++++--------
 .../plan/abilities/sink/RowLevelDeleteSpec.java    |  27 ++++-
 .../plan/abilities/sink/RowLevelUpdateSpec.java    |  25 +++-
 .../plan/nodes/exec/batch/BatchExecSink.java       |  66 ++++++++++
 .../plan/nodes/exec/common/CommonExecSink.java     |   4 +-
 .../factories/TestUpdateDeleteTableFactory.java    | 125 ++++++++++++++++---
 .../runtime/batch/sql/DeleteTableITCase.java       |  47 +++++++-
 .../runtime/batch/sql/UpdateTableITCase.java       |  40 ++++++
 9 files changed, 385 insertions(+), 85 deletions(-)