Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5578#discussion_r170943110 --- 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 --- End diff -- This annotation does not fit here.
---