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 99bf496b41c [FLINK-36049][table-planner] Add CompiledPlan annotations
to BatchExecSortLimit
new 308f05a911d [hotfix] Refactor SourceOperatorSlitWatermarkAlignmentTest
and support pausing splits in MockSourceReader
new 287eff2d1ca [hotfix][test] Do not add three splits with the same
splitId in testMetrics
new 8ad03460f04 [FLINK-35886][task] Define RelativeClock interface
new 8476664ab13 [FLINK-35886][task] Support markStart and markEnd
listeners in TimerGauge
new 9659a5c3e62 [FLINK-35886][task] Implement PausableRelativeClock
new 934007cf2b9 [FLINK-35886][task] Use RelativeClock in
WatermarksWithIdleness
new a76c711db61 [FLINK-35886][task] Expose Clock from ProcessingTimeService
new 49eaba0b8f0 [FLINK-35886][task] Hide backpressure from idleness
detection in TimestampsAndWatermarksOperator
new 02d89caede0 [FLINK-35886][task] Hide backpressure and watermark
alignment from idleness detection in SourceOperator
new 6d100ab09c5 [FLINK-35886][task] Hide backpressure from idleness
detection in WatermarkAssignerOperator
new 5f6200c7191 [FLINK-35886][source] Do not track already finished splits
in watermark alignment
The 11 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:
.../eventtime/WatermarkGeneratorSupplier.java | 12 +-
.../eventtime/WatermarkStrategyWithIdleness.java | 4 +-
.../common/eventtime/WatermarksWithIdleness.java | 25 +-
.../java/org/apache/flink/util/clock/Clock.java | 2 +-
.../org/apache/flink/util/clock/RelativeClock.java | 24 +-
.../common/eventtime/WatermarkStrategyTest.java | 15 +-
.../connector/source/mocks/MockSourceReader.java | 39 ++-
.../flink/table/toolbox/TestSourceFunction.java | 17 +-
.../runtime/NeverFireProcessingTimeService.java | 6 +-
.../apache/flink/runtime/metrics/TimerGauge.java | 60 ++++-
.../runtime/metrics/groups/TaskIOMetricGroup.java | 10 +
.../flink/runtime/metrics/TimerGaugeTest.java | 58 +++++
.../streaming/api/operators/SourceOperator.java | 32 ++-
.../source/NoOpTimestampsAndWatermarks.java | 6 +
.../source/ProgressiveTimestampsAndWatermarks.java | 80 ++++++-
.../operators/source/TimestampsAndWatermarks.java | 49 +++-
.../source/TimestampsAndWatermarksContext.java | 11 +-
.../operators/source/WatermarkToDataOutput.java | 3 +
.../api/operators/util/PausableRelativeClock.java | 96 ++++++++
.../operators/TimestampsAndWatermarksOperator.java | 36 ++-
.../runtime/tasks/ProcessingTimeService.java | 10 +
.../runtime/tasks/ProcessingTimeServiceImpl.java | 5 +-
.../runtime/tasks/SystemProcessingTimeService.java | 6 +-
.../SourceOperatorSplitWatermarkAlignmentTest.java | 262 ++++++++++++++++++---
.../operators/util/PausableRelativeClockTest.java | 80 +++++++
.../TimestampsAndWatermarksOperatorTest.java | 42 ++++
.../runtime/tasks/MultipleInputStreamTaskTest.java | 4 +-
.../runtime/tasks/TestProcessingTimeService.java | 66 +++++-
.../util/AbstractStreamOperatorTestHarness.java | 4 +
.../factories/TestValuesRuntimeFunctions.java | 17 +-
.../codegen/WatermarkGeneratorCodeGenTest.scala | 5 +-
.../wmassigners/WatermarkAssignerOperator.java | 21 +-
.../wmassigners/WatermarkAssignerOperatorTest.java | 29 +++
33 files changed, 1014 insertions(+), 122 deletions(-)
copy
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/splitreader/SplitsAddition.java
=> flink-core/src/main/java/org/apache/flink/util/clock/RelativeClock.java
(62%)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/PausableRelativeClock.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/util/PausableRelativeClockTest.java
