Hi everyone,

Flink 0.10.1
Hadoop 2.4.0

Fairly new to Flink here, so my question might be simple but couldn't find something relevant in the docs. I am implementing a Flink client that submits jobs to a Flink Yarn cluster. At the moment I am using the Client and PackagedProgram classes which are working fine, however the latter expects the job jar to be available locally so that the Client can submit it to the Flink Yarn cluster.

Is it possible to use a job jar that is already stored in the HDFS of the cluster where Flink is running on, without first copying it locally to where the Client is?

Thank you,
Theofilos

Reply via email to