|
|
Which Flink version are you using? The DISABLED value has not been
working since 1.5, so you may be stuck with uploading the app jar every
time.
On 04/04/2019 11:35, 徐涛 wrote:
> Hi Experts,
> When submitting a Flink program to Yarn, the app jar( a fat jar about 200M with Flink dependencies ) will be uploaded to Yarn, which will take a lot of time. I check the code in CliFrontend, and found that there is a config item named “yarn.per-job-cluster.include-user-jar”, I try to set the config item value to “DISABLED”, the fat jar will not be uploaded, but I have to set the CLASSPATH environment of the Yarn container, to point to a route on HDFS. Also I found a config item starts with “containerized.master.env.”, I set the “containerized.master.env.CLASSPATH” value to "hdfs://xm-hdfs-test-01/henry/flink-application-0.0.1-SNAPSHOT-uber.jar”, but with no luck. I also found that the ConfigConstants.CONTAINERIZED_MASTER_ENV_PREFIX variable is marked as deprecated, so maybe I can not use it.
> So how could this requirement be implemented? Because I think it will save a lot of time to start the Flink program.
>
> Best
> Henry
|
Locked
