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/02/04 18:31:05 UTC

[flink] branch master updated (b2131e4 -> 5f4659f)

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 b2131e4  [FLINK-25725][table][tests] Use GlobalCommitter for CompactManagedTableITCase
     add 5f4659f  [FLINK-25578][core] Graduate and deprecate unified Sink API V1

No new revisions were added by this update.

Summary of changes:
 .../5b9eed8a-5fb6-4373-98ac-3be2a71941b8           | 12 ----------
 .../7602816f-5c01-4b7a-9e3e-235dfedec245           |  4 ----
 .../apache/flink/api/connector/sink/Committer.java |  6 +++--
 .../flink/api/connector/sink/GlobalCommitter.java  |  7 ++++--
 .../org/apache/flink/api/connector/sink/Sink.java  | 26 +++++++++++++++++++---
 .../flink/api/connector/sink/SinkWriter.java       | 15 ++++++++++---
 .../flink/streaming/api/datastream/DataStream.java |  3 +--
 .../flink/table/connector/sink/SinkProvider.java   |  4 ++++
 8 files changed, 49 insertions(+), 28 deletions(-)