[ https://issues.apache.org/jira/browse/FLINK-6633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16056527#comment-16056527 ]
Cliff Resnick commented on FLINK-6633: -------------------------------------- Ok, new gist is here: https://gist.github.com/cresny/87c997b558064a7ec5e8021ae7456653 This one cancels job after two checkpoints, first checkpoint after recovery fails with Placeholder serialization attempt. > Register with shared state registry before adding to CompletedCheckpointStore > ----------------------------------------------------------------------------- > > Key: FLINK-6633 > URL: https://issues.apache.org/jira/browse/FLINK-6633 > Project: Flink > Issue Type: Sub-task > Components: State Backends, Checkpointing > Affects Versions: 1.3.0 > Reporter: Stefan Richter > Assignee: Stefan Richter > Priority: Blocker > Fix For: 1.3.0 > > > Introducing placeholders for previously existing shared state requires a > change that shared state is first registering with {{SharedStateregistry}} > (thereby being consolidated) and only after that added to a > {{CompletedCheckpointStore}}, so that the consolidated checkpoint is written > to stable storage. -- This message was sent by Atlassian JIRA (v6.4.14#64029)