[ https://issues.apache.org/jira/browse/FLINK-25445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471347#comment-17471347 ]
Junfan Zhang commented on FLINK-25445: -------------------------------------- Do you mind i take over this ticket? [~zjureel] I'm learn the code of task local-recovery and interested on it. > TaskExecutor always creates local file for task even when local state store > is not used > --------------------------------------------------------------------------------------- > > Key: FLINK-25445 > URL: https://issues.apache.org/jira/browse/FLINK-25445 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Coordination > Affects Versions: 1.12.7, 1.13.5, 1.14.2 > Reporter: Shammon > Priority: Major > Labels: pull-request-available > > `TaskExecutor` will create file, check `localRecoveryEnabled` and load local > state store for each task submission in method `localStateStoreForSubtask`. > For batch jobs, the `localRecoveryEnabled` is always false, and there's no > need to create these local files for task in `TaskExecutor` -- This message was sent by Atlassian Jira (v8.20.1#820001)