[jira] [Created] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode

Shang Yuanchun (Jira)
Zhenqiu Huang created FLINK-14033:
-------------------------------------

             Summary: 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


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)