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 8543334 [hotfix][test] Clean up the test code in SourceStreamTaskTest
and OneInputStreamTaskTest
new 126cff6 [hotfix] Extract utils of CheckpointCoordinatorTest into a
separate utils class and correct codestyle
new 22c3248 [hotfix] Split too large file CheckpointCoordinatorTest.java
into several small files
new 3c84c05 [hotfix] Correct code style of CheckpointCoordinator
new 5ab6261 [FLINK-13904][checkpointing] Make trigger thread of
CheckpointCoordinator single-threaded
new fc19673 [FLINK-13904][tests] Support checkpoint consumer of
SimpleAckingTaskManagerGateway
new 41cda38 [FLINK-13904][checkpointing] Avoid competition between
savepoint and periodic checkpoint triggering
new 00fe29b [FLINK-13904][checkpointing] Remove trigger lock of
CheckpointCoordinator
new beb3fb0 [FLINK-13904][checkpointing] Encapsule and optimize the time
relevant operation of CheckpointCoordinator
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:
.../runtime/checkpoint/CheckpointCoordinator.java | 360 ++--
.../runtime/executiongraph/ExecutionGraph.java | 19 +
.../CheckpointCoordinatorFailureTest.java | 12 +-
.../CheckpointCoordinatorMasterHooksTest.java | 40 +-
.../CheckpointCoordinatorRestoringTest.java | 1014 ++++++++++
.../checkpoint/CheckpointCoordinatorTest.java | 2065 +++-----------------
.../CheckpointCoordinatorTestingUtils.java | 569 ++++++
.../CheckpointCoordinatorTriggeringTest.java | 313 +++
.../checkpoint/CheckpointStateRestoreTest.java | 12 +-
.../FailoverStrategyCheckpointCoordinatorTest.java | 62 +-
.../ManuallyTriggeredScheduledExecutor.java | 123 +-
.../utils/SimpleAckingTaskManagerGateway.java | 37 +-
.../runtime/messages/CheckpointMessagesTest.java | 13 +-
.../runtime/util/TestingScheduledExecutor.java | 62 +
14 files changed, 2645 insertions(+), 2056 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorRestoringTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTestingUtils.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTriggeringTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/util/TestingScheduledExecutor.java
