This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 004d3b5 [FLINK-22898][Connectors/Hive] return default-parallelism in
HiveParallelismInference when there is no source infer
new 7c6b026 [FLINK-23201][streaming] Calculate checkpoint alignment time
only for last started checkpoint
new b6d89fe [FLINK-23201][streaming] Reset alignment only for the
currently processed checkpoint
The 2 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:
.../io/checkpointing/CheckpointBarrierHandler.java | 38 ++++++++---
.../io/checkpointing/CheckpointBarrierTracker.java | 11 +++-
.../SingleCheckpointBarrierHandler.java | 7 +-
.../checkpointing/AlternatingCheckpointsTest.java | 28 ++++++++
.../CheckpointBarrierTrackerTest.java | 76 +++++++++++++++++++++-
5 files changed, 142 insertions(+), 18 deletions(-)
