Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5578#discussion_r170946385 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStoreImpl.java --- @@ -90,6 +92,10 @@ @GuardedBy("lock") private boolean disposed; + /** Whether to discard the useless state when retrieve local checkpoint state. */ + @Nonnull + private boolean retrieveWithDiscard; --- End diff -- Why not make this a general default?
---