[jira] [Created] (FLINK-20222) The CheckpointCoordinator should reset the OperatorCoordinators when fail before the first checkpoint.

[Shang Yuanchun (Jira)]

Jiangjie Qin created FLINK-20222:
------------------------------------

             Summary: The CheckpointCoordinator should reset the OperatorCoordinators when fail before the first checkpoint.
                 Key: FLINK-20222
                 URL: https://issues.apache.org/jira/browse/FLINK-20222
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Checkpointing
            Reporter: Jiangjie Qin


Right now, if a job failed before the first successful checkpoint, the CheckpointCoordinator will not reset the OperatorCoordinator state. This may leave the OperatorCoordinators in inconsistent state.

The CheckpointCoordinator should also reset the OperatorCoordinator state in this case, just like it does for the master hooks. It essentially means "reset to no checkpoint". There are two options for the fix:
 # Add a reset() method to the OperatorCoordinator.
 # Call resetToCheckpoint(null) on the OperatorCoordinator.



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