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 958fc80 [FLINK-20141] Update Connectors main doc page for FS sinks
add b878f54 [FLINK-20169] Move emitting MAX_WATERMARK out of the
SourceOperator processing loop
No new revisions were added by this update.
Summary of changes:
.../streaming/api/operators/SourceOperator.java | 13 ++-------
.../runtime/tasks/SourceOperatorStreamTask.java | 8 ++++++
.../api/operators/SourceOperatorTest.java | 20 +-------------
.../source/SourceOperatorEventTimeTest.java | 4 +--
.../tasks/SourceOperatorStreamTaskTest.java | 32 +++++++++++++++++++++-
.../tasks/StreamTaskMailboxTestHarness.java | 13 ++++++---
6 files changed, 53 insertions(+), 37 deletions(-)
