Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r170268121 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java --- @@ -141,7 +147,7 @@ public JobLeaderService getJobLeaderService() { return jobLeaderService; } - public TaskExecutorLocalStateStoresManager getTaskStateManager() { + public TaskExecutorLocalStateStoresManager getTaskManagerStateStore() { return taskStateManager; --- End diff -- ð
---