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 fe06d668087 hotfix][docs] Fix uv PATH for Chinese docs build in CI
new deadc2154f8 [hotfix][tests] Extract updateIntervalMillis in
SourceOperatorAlignmentTest
new 476e27a37ed [hotfix][tests] Refactor
SourceOperatorSplitWatermarkAlignmentTest
new f4d8e4b543a [hotfix][tests] Create Builder for
SourceOperatorTestContext
new e03da5e0538 [FLINK-37399][runtime] Add SamplingWatermarkRingBuffer
new bda5c7c3f67 [FLINK-37399][runtime][source] Buffer watermarks for
watermark alignment
new 774fd077bd0 [FLINK-37399][tests] Randomize watermark alignment buffer
size in ITCases
new 68aca153e0a [FLINK-37399][docs] Regenerate docs
new 825400b6f65 [hotfix] Fix formatting
The 8 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:
.../generated/pipeline_configuration.html | 6 +
.../source/reader/AlignedWatermarksITCase.java | 9 +-
.../flink/configuration/PipelineOptions.java | 25 ++++
.../streaming/api/operators/SourceOperator.java | 74 +++++++++---
.../api/operators/source/WatermarkSampler.java | 66 ++++++++++
.../api/operators/SourceOperatorAlignmentTest.java | 129 ++++++++++++++------
.../api/operators/SourceOperatorIdleTest.java | 2 +-
.../SourceOperatorSplitWatermarkAlignmentTest.java | 107 +++++++++++-----
.../api/operators/SourceOperatorTest.java | 80 ++++++------
.../api/operators/SourceOperatorTestContext.java | 134 ++++++++++++---------
.../operators/SourceOperatorWatermarksTest.java | 20 +--
.../operators/source/TestingSourceOperator.java | 4 +-
.../api/operators/source/WatermarkSamplerTest.java | 97 +++++++++++++++
.../plan/rules/logical/RemoteCallFinder.java | 2 +
.../streaming/util/TestStreamEnvironment.java | 3 +
15 files changed, 561 insertions(+), 197 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/source/WatermarkSampler.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/streaming/api/operators/source/WatermarkSamplerTest.java
