This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 869f6b0 [FLINK-23095][runtime] Close the channel unspilling thread
pool after restore
add c0244d3 [FLINK-22700] [api] Propagate watermarks to sink API
(FLIP-167)
No new revisions were added by this update.
Summary of changes:
.../flink/api/connector/sink/SinkWriter.java | 11 +++++++++++
.../streaming/api/functions/sink/SinkFunction.java | 12 +++++++++++
.../flink/streaming/api/operators/StreamSink.java | 2 ++
.../operators/sink/AbstractSinkWriterOperator.java | 2 ++
.../api/operators/StreamSinkOperatorTest.java | 18 +++++++++++++++++
.../operators/sink/SinkWriterOperatorTestBase.java | 23 ++++++++++++++++++++++
.../streaming/runtime/operators/sink/TestSink.java | 9 +++++++++
.../streaming/api/FileReadingWatermarkITCase.java | 10 +++++++---
8 files changed, 84 insertions(+), 3 deletions(-)
