Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5074#discussion_r153493396
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java
---
@@ -190,6 +199,11 @@ public static TaskManagerServices fromConfiguration(
final JobLeaderService jobLeaderService = new
JobLeaderService(taskManagerLocation);
+ final CheckpointCacheManager checkpointCacheManager = new
CheckpointCacheManager(
+ new ScheduledThreadPoolExecutor(1),
+ Executors.directExecutor(),
+ taskManagerServicesConfiguration.getTmpDirPaths()[0]);
--- End diff --
You're right. I even thought we should add a configuration for local
recovery to store the data.
---
