[
https://issues.apache.org/jira/browse/FLINK-7595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-7595:
-------------------------------
Attachment: ChainedTaskRemoveTest.java
I've attached a test that produces the problem (if I'm correct that this is a
bug).
> Removing stateless task from task chain breaks savepoint restore
> ----------------------------------------------------------------
>
> Key: FLINK-7595
> URL: https://issues.apache.org/jira/browse/FLINK-7595
> Project: Flink
> Issue Type: Bug
> Components: State Backends, Checkpointing
> Reporter: Ufuk Celebi
> Assignee: Chesnay Schepler
> Attachments: ChainedTaskRemoveTest.java
>
>
> When removing a stateless operator from a 2-task chain where the head
> operator is stateful breaks savepoint restore with
> {code}
> Caused by: java.lang.IllegalStateException: Failed to rollback to savepoint
> /var/folders/py/s_1l8vln6f19ygc77m8c4zhr0000gn/T/junit1167397515334838028/junit8006766303945373008/savepoint-cb0bcf-3cfa67865ac0.
> Cannot map savepoint state...
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
