Stephan Ewen created FLINK-2515:
-----------------------------------
Summary: CheckpointCoordinator triggers checkpoints even if not all sources are running any more
Key: FLINK-2515
URL:
https://issues.apache.org/jira/browse/FLINK-2515 Project: Flink
Issue Type: Bug
Components: JobManager
Affects Versions: 0.10
Reporter: Stephan Ewen
Priority: Blocker
Fix For: 0.10
When some sources finish early, they will not emit checkpoint barriers any more. That means that pending checkpoint alignments will never be able to complete, locking the flow.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)