[
https://issues.apache.org/jira/browse/FLINK-25445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484303#comment-17484303
]
Shammon commented on FLINK-25445:
---------------------------------
Sure, thanks [~zuston] to take this issue :)
> 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)
