[jira] [Updated] (FLINK-20397) Pass checkpointId to OperatorCoordinator.resetToCheckpoint().

["Xintong Song (Jira)" <ji...@apache.org>]

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

Xintong Song updated FLINK-20397:
---------------------------------
    Fix Version/s: 1.11.3

> Pass checkpointId to OperatorCoordinator.resetToCheckpoint().
> -------------------------------------------------------------
>
>                 Key: FLINK-20397
>                 URL: https://issues.apache.org/jira/browse/FLINK-20397
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Coordination
>    Affects Versions: 1.11.2
>            Reporter: Stephan Ewen
>            Assignee: Stephan Ewen
>            Priority: Major
>             Fix For: 1.12.0, 1.11.3
>
>
> The OperatorCoordinator.resetToCheckpoint() currently lacks the information which checkpoint it recovers to.
> That forces implementers to assume strict ordering of method calls between restore and failure. While that is currently guaranteed in this case, it is not guaranteed in other places (see parent issue).
> Because of that, we want implementations to not assume method order at all, but rely on explicit information passed to the methods (checkpoint IDs). Otherwise we end up with mixed implementations that partially infer context from the order of method calls, and partially use explicit information that was passed.



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