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 f57a537 [FLINK-25833][core] FlinkUserCodeClassLoader is registered as
parallel capable
new 1e7d45d [FLINK-25958][refactor][runtime] Separated the logic of
creating and reporting the statistic in order to use it in different place in
the future
new dc419b5 [FLINK-25958][runtime] Mark CompletedCheckpoint as discarded
before it will be really discarded in order to avoid synchronization for
changing discarded flag
new 906f324 [FLINK-25958][runtime] Report completed statistic only after
the completed checkpoint will be added to checkpoint store
new fbfdb0e [FLINK-25958][runtime] Report failed statistic if adding of
completed checkpoint to checkpoint store fails
The 4 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:
.../flink/runtime/checkpoint/Checkpoint.java | 14 ++-
.../runtime/checkpoint/CheckpointCoordinator.java | 77 +++++++++---
.../runtime/checkpoint/CheckpointStatsTracker.java | 43 +------
.../flink/runtime/checkpoint/Checkpoints.java | 3 +-
.../runtime/checkpoint/CheckpointsCleaner.java | 20 +--
.../runtime/checkpoint/CompletedCheckpoint.java | 138 ++++++++++-----------
.../checkpoint/CompletedCheckpointStats.java | 26 +---
.../EmbeddedCompletedCheckpointStore.java | 4 +-
.../runtime/checkpoint/FailedCheckpointStats.java | 17 ---
.../runtime/checkpoint/PendingCheckpoint.java | 132 +++++++++++---------
.../runtime/checkpoint/PendingCheckpointStats.java | 90 +++++---------
.../StandaloneCompletedCheckpointStore.java | 10 +-
.../CheckpointCoordinatorFailureTest.java | 31 ++++-
.../CheckpointCoordinatorMasterHooksTest.java | 6 +-
.../CheckpointCoordinatorRestoringTest.java | 9 +-
.../checkpoint/CheckpointCoordinatorTest.java | 34 ++++-
.../checkpoint/CheckpointStateRestoreTest.java | 6 +-
.../checkpoint/CheckpointStatsTrackerTest.java | 16 +--
.../checkpoint/CompletedCheckpointStoreTest.java | 49 +++-----
.../checkpoint/CompletedCheckpointTest.java | 70 +++++++----
.../DefaultCompletedCheckpointStoreTest.java | 3 +-
.../DefaultCompletedCheckpointStoreUtilsTest.java | 3 +-
.../checkpoint/PendingCheckpointStatsTest.java | 32 ++---
.../runtime/checkpoint/PendingCheckpointTest.java | 105 ++--------------
.../StandaloneCompletedCheckpointStoreTest.java | 5 +-
.../ZooKeeperCompletedCheckpointStoreTest.java | 3 +-
.../flink/runtime/jobmaster/JobMasterTest.java | 3 +-
.../runtime/scheduler/SchedulerUtilsTest.java | 3 +-
...topWithSavepointTerminationHandlerImplTest.java | 3 +-
29 files changed, 450 insertions(+), 505 deletions(-)
