You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by pn...@apache.org on 2019/11/12 13:07:36 UTC

[flink] branch master updated (36d1b62 -> b5da461)

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 36d1b62  [hotfix] Preserve the singleton property for ResourceProfile#ANY.
     add e2b6548  [FLINK-14344][checkpointing] PendingCheckpoint supports acknowledging master state
     add 5522461  [hotfix] Correct code style of MasterTriggerRestoreHook
     add d282c98  [FLINK-14344][checkpointing] Emphasize that MasterTriggerRestoreHook#triggerCheckpoint should be non-blocking in java doc
     add 82c2057  [FLINK-14344][checkpointing] MasterHooks class supports asynchronous triggering
     add b5da461  [hotfix] Correct the acknowledging method name of PendingCheckpoint

No new revisions were added by this update.

Summary of changes:
 .../runtime/checkpoint/CheckpointCoordinator.java  |  16 +--
 .../checkpoint/MasterTriggerRestoreHook.java       |  53 ++++----
 .../runtime/checkpoint/PendingCheckpoint.java      |  43 +++++--
 .../runtime/checkpoint/hooks/MasterHooks.java      | 140 ++++++++-------------
 .../CheckpointCoordinatorMasterHooksTest.java      |  30 +----
 .../checkpoint/CheckpointCoordinatorTest.java      |  26 ++--
 .../CheckpointCoordinatorTestingUtils.java         |  31 ++++-
 .../runtime/checkpoint/PendingCheckpointTest.java  | 138 +++++++++++++++++++-
 .../runtime/checkpoint/hooks/TestMasterHook.java   |   4 +-
 9 files changed, 296 insertions(+), 185 deletions(-)