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)