[ https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182475#comment-16182475 ]
ASF GitHub Bot commented on FLINK-7683: --------------------------------------- Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4722 We have got carried away with those concurrent modifications and snapshots. To rewrite keyed state variable from an old to a new one, old is used as a read only. Thus `getKeys` for the the old one doesn't have to care about any modifications. I have reverted snapshot rocks db changes. > Add method to iterate over all of the existing keys in a statebackend > --------------------------------------------------------------------- > > Key: FLINK-7683 > URL: https://issues.apache.org/jira/browse/FLINK-7683 > Project: Flink > Issue Type: New Feature > Components: State Backends, Checkpointing > Reporter: Piotr Nowojski > Assignee: Piotr Nowojski > > This is required to make possible preserving backward compatibility while > changing state definition of a keyed state operator (to do so operator must > iterate over all of the existing keys and rewrites them into a new state > variable). -- This message was sent by Atlassian JIRA (v6.4.14#64029)