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 17:35:56 UTC

[flink] branch master updated (5846d8d -> b2131e4)

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 5846d8d  [FLINK-25573][kafka] Migrate KafkaSink to SinkV2
     add 051ad67  [FLINK-25726][streaming] Check committer existence in SinkV1Adapter to determine if a committer is needed
     add 03efde4  [FLINK-25726][streaming] Add Global Committer as post commit topology
     add b2131e4  [FLINK-25725][table][tests] Use GlobalCommitter for CompactManagedTableITCase

No new revisions were added by this update.

Summary of changes:
 .../connector/sink2/GlobalCommitterOperator.java   | 156 +++++++++++++++++++++
 .../connector/sink2/StandardSinkTopologies.java    |  25 +++-
 .../api/transformations/SinkTransformation.java    |   3 +
 .../api/transformations/SinkV1Adapter.java         |  14 +-
 .../translators/SinkTransformationTranslator.java  |  18 ++-
 .../sink2/GlobalCommitterOperatorTest.java         | 136 ++++++++++++++++++
 .../graph/SinkTransformationTranslatorTest.java    |  39 ++++--
 .../api/transformations/SinkV1AdapterTest.java     |  16 +++
 .../table/connector/sink/TestManagedSink.java      |  15 +-
 .../connector/sink/TestManagedSinkCommitter.java   |  44 ++++--
 .../batch/sql/CompactManagedTableITCase.java       |   2 -
 .../flink/test/streaming/runtime/SinkITCase.java   |   5 +-
 12 files changed, 428 insertions(+), 45 deletions(-)
 create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/connector/sink2/GlobalCommitterOperator.java
 create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/connector/sink2/GlobalCommitterOperatorTest.java