[
https://issues.apache.org/jira/browse/FLINK-20397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-20397.
--------------------------------
> 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
>
>
> 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)
