This is an automated email from the ASF dual-hosted git repository.
rkhachatryan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 746df693a1e [hotfix][docs] Stop nightly docs builds for release-1.19,
release-2.0 and release-2.1
new 91e1e5fba04 [FLINK-40504][core] Make PartialWatermark idleness
tri-state
new 577dd116f56 [FLINK-40504][runtime] Mark WatermarkToDataOutput active
on non-advancing watermarks
new c85dca720a3 [FLINK-40504][core] Report activity from
WatermarksWithIdleness on events
new 0897586aa50 [FLINK-40504][core] Propagate active combined status from
WatermarkOutputMultiplexer
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../common/eventtime/CombinedWatermarkStatus.java | 41 +++-
.../eventtime/WatermarkOutputMultiplexer.java | 13 +
.../common/eventtime/WatermarksWithIdleness.java | 20 +-
.../eventtime/WatermarkOutputMultiplexerTest.java | 107 ++++++++
.../eventtime/WatermarksWithIdlenessTest.java | 20 ++
.../operators/source/WatermarkToDataOutput.java | 18 +-
...TimestampsAndWatermarksSubtaskIdlenessTest.java | 271 +++++++++++++++++++++
.../source/SourceOperatorEventTimeTest.java | 33 +++
.../source/WatermarkToDataOutputTest.java | 15 ++
9 files changed, 528 insertions(+), 10 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/streaming/api/operators/source/ProgressiveTimestampsAndWatermarksSubtaskIdlenessTest.java
