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(-)
