Andrey Zagrebin created FLINK-10132: ---------------------------------------
Summary: Incremental cleanup of local expired state with TTL discovered in full snapshot Key: FLINK-10132 URL: https://issues.apache.org/jira/browse/FLINK-10132 Project: Flink Issue Type: Improvement Components: State Backends, Checkpointing Affects Versions: 1.7.0 Reporter: Andrey Zagrebin Assignee: Andrey Zagrebin Fix For: 1.7.0 This issue suggests to extend approach from FLINK-9938 and add a queue between a snapshotting thread which discovers expired state during its full scan and main thread which accesses state and can incrementally pull the queue and clean up local state if still applicable. -- This message was sent by Atlassian JIRA (v7.6.3#76005)