This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c46b203 [FLINK-21084][runtime][checkpoint] CheckpointCoordinator
records finished state for operators in tasks finished on restore
add 54e4d71 [FLINK-23371][streaming-java] Allow disabling progressive
watermarks for SourceFunction
add 47627b2 [FLINK-23371][table-planner] Disable progressive watermarks
for bounded SourceFunctions
No new revisions were added by this update.
Summary of changes:
.../source/ContinuousFileReaderOperator.java | 3 +-
.../streaming/api/operators/StreamSource.java | 19 +++++++++--
.../api/operators/StreamSourceContexts.java | 21 +++++++++---
.../StreamSourceContextIdleDetectionTests.java | 6 ++--
.../StreamSourceOperatorWatermarksTest.java | 37 +++++++++++++++++++++-
.../exec/common/CommonExecTableSourceScan.java | 2 +-
.../plan/nodes/exec/TransformationsTest.java | 2 ++
7 files changed, 78 insertions(+), 12 deletions(-)
