Stephan Ewen created FLINK-4321: ----------------------------------- Summary: Initialize TaskExecutions directly with their starting state Key: FLINK-4321 URL: https://issues.apache.org/jira/browse/FLINK-4321 Project: Flink Issue Type: Sub-task Components: Distributed Coordination Affects Versions: 1.1.0 Reporter: Stephan Ewen Assignee: Stephan Ewen Fix For: 1.2.0
Currently, the CheckpointCoordinator injects state into the Executions of each vertex. For more file grained recovery, not all executions need state at the same time, and different executions may be scheduled at different points in time with different completed checkpoints. Executions should hence be eagerly initialized with their checkpoint state handles. -- This message was sent by Atlassian JIRA (v6.3.4#6332)