This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from b8ff60d [FLINK-23262][tests] Check watermark frequency instead of count add ba58c62 [FLINK-23080][datastream] Introduce SinkFunction#finish() method. add 49f6d6f [FLINK-23080] Add finish() for the TwoPhaseCommitSink No new revisions were added by this update. Summary of changes: .../kafka/table/BufferedUpsertSinkFunction.java | 21 ++++++++++++--------- .../streaming/api/functions/sink/SinkFunction.java | 16 ++++++++++++++++ .../functions/sink/TwoPhaseCommitSinkFunction.java | 15 +++++++++++++++ .../api/operators/AbstractUdfStreamOperator.java | 9 +++++++++ 4 files changed, 52 insertions(+), 9 deletions(-)