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 1e42bb4 [FLINK-19712][Coordination] Do not restart CREATED executions
in RestartPipelinedRegionFailoverStrategy
add fada6fb [FLINK-18820] Emit MAX_WATERMARK at the end in SourceOperator
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 | 12 +++--
.../tasks/SourceOperatorStreamTaskTest.java | 57 ++++++++++++++++------
5 files changed, 87 insertions(+), 23 deletions(-)
