Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5578#discussion_r170965699
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStoreImpl.java
---
@@ -285,4 +316,9 @@ public String toString() {
", localRecoveryConfig=" + localRecoveryConfig +
'}';
}
+
+ @VisibleForTesting
+ void setRetrieveWithDiscard(@Nonnull boolean retrieveWithDiscard) {
--- End diff --
addressed.---
