You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/02/12 10:45:00 UTC
[jira] [Commented] (FLINK-9648) Do not store distributed cache
entries in ExecutionConfig
[ https://issues.apache.org/jira/browse/FLINK-9648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283603#comment-17283603 ]
Till Rohrmann commented on FLINK-9648:
--------------------------------------
[~chesnay] shall we do this later and close it for the time being?
> Do not store distributed cache entries in ExecutionConfig
> ---------------------------------------------------------
>
> Key: FLINK-9648
> URL: https://issues.apache.org/jira/browse/FLINK-9648
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Coordination, Runtime / Task
> Reporter: Chesnay Schepler
> Priority: Major
>
> Currently, {{DistributedCacheEntries}} are written into the {{ExecutionConfig}} on the client and later extracted again by the {{FileCache}} on the {{TaskManager}}.
> This approach is more complex and error-prone than necessary, as the map of entries are already serializable, and in fact are already sent to the JobManager.
> We can instead simply store the map of entries directly in the {{TaskDeploymentDescriptor}}.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)