[ 
https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930302#comment-16930302
 ] 

Yang Wang commented on FLINK-14033:
-----------------------------------

Seems that UserArtifacts is not added to yarn distributed cache and then upload 
to blob server so that it could be accessed by
 all tasks. The jars have been added to yarn distributed cache and do not need 
to put into blob server, because they have been added into system classpath.

> Distributed caches are not registered in Yarn Per Job Cluster Mode
> ------------------------------------------------------------------
>
>                 Key: FLINK-14033
>                 URL: https://issues.apache.org/jira/browse/FLINK-14033
>             Project: Flink
>          Issue Type: Bug
>          Components: Deployment / YARN
>    Affects Versions: 1.9.0
>            Reporter: Zhenqiu Huang
>            Assignee: Zhenqiu Huang
>            Priority: Minor
>
> CacheFiles in StreamExecutionEnvironment is not used in Job Submission in the 
> Yarn per job cluster mode. Compare to the job submission in session cluster 
> mode that will upload distributed cache files onto http server in application 
> master, we should get the cache files in job graph and register them into 
> blob store in YarnJobClusterEntrypoint.



--
This message was sent by Atlassian Jira
(v8.3.2#803003)

Reply via email to