Find file History
Latest commit cfb95b9 Jan 20, 2017 @tillrohrmann tillrohrmann [FLINK-5229] [state] Cleanup of operator snapshots if subsequent oper…
…ator snapshots fail

This PR adds operator state cleanup to the StreamTask class. If a stream task contains multiple
stream operators, then every operator is checkpointed. In case that a snapshot operation fails
all state handles and OperatorSnapshotResults belonging to previous operators have to be freed.

Add test cases for failing checkpoint operations in StreamTask

Address PR comments

This closes #3179.