This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0cf7c3d [FLINK-26068] Update ZooKeeperStateHandleStore to use an
indepotent replace operation for #setStateHandle, that has been introduced in
CURATOR-584, to avoid possible BadVersionException during connection issues.
add 7e56e85 [hotfix][test] Move test only used method to test
add 40dc2b4 [FLINK-24441][source] Block SourceOperator when watermarks
are out of alignment
No new revisions were added by this update.
Summary of changes:
.../source/coordinator/SourceCoordinator.java | 4 +
.../streaming/api/operators/SourceOperator.java | 95 +++++++++-
.../source/NoOpTimestampsAndWatermarks.java | 3 +-
.../source/ProgressiveTimestampsAndWatermarks.java | 5 +-
.../source/SourceOutputWithWatermarks.java | 20 --
.../operators/source/TimestampsAndWatermarks.java | 9 +-
.../operators/source/WatermarkToDataOutput.java | 13 +-
.../api/operators/SourceOperatorAlignmentTest.java | 202 +++++++++++++++++++++
.../api/operators/SourceOperatorTestContext.java | 28 ++-
.../api/operators/source/CollectingDataOutput.java | 7 +-
.../source/SourceOutputWithWatermarksTest.java | 25 ++-
.../operators/source/TestingSourceOperator.java | 28 +--
12 files changed, 388 insertions(+), 51 deletions(-)
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorAlignmentTest.java
