[ https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903110#comment-15903110 ]
Gyula Fora commented on FLINK-5985: ----------------------------------- You can easily reproduce the bug locally by running the following simple program: https://gist.github.com/gyfora/b5ccf836dc9e95bab2b1f5f483cb8bf6 Take a savepoint and uncomment the stateless map before the sink to change the sink hash then restore. > Flink treats every task as stateful (making topology changes impossible) > ------------------------------------------------------------------------ > > Key: FLINK-5985 > URL: https://issues.apache.org/jira/browse/FLINK-5985 > Project: Flink > Issue Type: Bug > Components: State Backends, Checkpointing > Affects Versions: 1.2.0 > Reporter: Gyula Fora > Priority: Critical > > It seems that Flink treats every Task as stateful so changing the topology > is not possible without setting uid on every single operator. > If the topology has an iteration this is virtually impossible (or at least > gets super hacky) -- This message was sent by Atlassian JIRA (v6.3.15#6346)