This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git
from 1e2c2e69590 [FLINK-31834][Azure] Free up disk space before caching
add 8d98e6981f9 [FLINK-31632] Fix maxAllowedWatermark arithmetic overflow
when the source is idle
No new revisions were added by this update.
Summary of changes:
.../runtime/source/coordinator/SourceCoordinator.java | 15 ++++++++++++---
.../coordinator/SourceCoordinatorAlignmentTest.java | 16 ++++++++++++++++
.../api/operators/SourceOperatorAlignmentTest.java | 6 ++++++
3 files changed, 34 insertions(+), 3 deletions(-)