You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2019/11/13 10:53:00 UTC

[jira] [Closed] (FLINK-14344) A preparation for snapshotting master hook state asynchronously

     [ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Piotr Nowojski closed FLINK-14344.
----------------------------------
    Release Note: The contract of `MasterTriggerRestoreHook#triggerCheckpoint` (@PublicEvolving api) has changed - we now require it to be non-blocking. Any heavy operation should be executed asynchronously, for example using the given executor.  (was: Makes the semantic of MasterTriggerRestoreHook#triggerCheckpoint more clearer. It should be non-blocking, Any heavy operation should be executed asynchronously with given executor.)
      Resolution: Fixed

Merged to master as e2b654893d63d1fd55e6a4475a45b984e01b4165^..b5da46170733313abed0f6172691a67a681af280

> A preparation for snapshotting master hook state asynchronously
> ---------------------------------------------------------------
>
>                 Key: FLINK-14344
>                 URL: https://issues.apache.org/jira/browse/FLINK-14344
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Checkpointing
>            Reporter: Biao Liu
>            Assignee: Biao Liu
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.10.0
>
>          Time Spent: 20m
>  Remaining Estimate: 0h
>
> Currently we snapshot the master hook state synchronously. As a part of reworking threading model of {{CheckpointCoordinator}}, we have to make this non-blocking to satisfy the requirement of running in main thread.
> The behavior of snapshotting master hook state is similar to task state snapshotting. Master state snapshotting is taken before task state snapshotting. Because in master hook, there might be external system initialization which task state snapshotting might depend on.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)