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

[Shang Yuanchun (Jira)]

Stephan Ewen created FLINK-20397:
------------------------------------

             Summary: 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
             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)