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