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)
