Canbin Zheng created FLINK-16547:
------------------------------------
Summary: Corrent the order to write temporary files in
YarnClusterDescriptor#startAppMaster
Key: FLINK-16547
URL: https://issues.apache.org/jira/browse/FLINK-16547
Project: Flink
Issue Type: Improvement
Components: Deployment / YARN
Reporter: Canbin Zheng
Fix For: 1.11.0
Currently, in {{YarnClusterDescriptor#startAppMaster}}, we first write out and
upload the Flink Configuration file, then start to write out the JobGraph file
and set its name into the Flink Configuration object, the afterward setting is
not written into the Flink Configuration file so that it does not take effect
in the cluster side.
Since in the client-side we name the JobGraph file with the default value of
FileJobGraphRetriever.JOB_GRAPH_FILE_PATH option, the cluster side could
succeed in retrieving that file.
This ticket proposes to write out the JobGraph file before the Configuration
file to ensure that the setting of FileJobGraphRetriever.JOB_GRAPH_FILE_PATH is
delivered to the cluster side.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
