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 a9ae79b1867 [FLINK-40015] Introduce getFunctionOutput in PTF Test
Harness (#28657)
add a8835bd3731 [FLINK-40093][Runtime] Resume idle splits by alignment
check if previously paused
No new revisions were added by this update.
Summary of changes:
.../groups/InternalSourceSplitMetricGroup.java | 5 +-
.../streaming/api/operators/SourceOperator.java | 10 ++--
.../SourceOperatorSplitWatermarkAlignmentTest.java | 60 ++++++++++++++++++++++
3 files changed, 69 insertions(+), 6 deletions(-)
