Submit Flink job programatically

Posted by Jins George on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Submit-Flink-job-programatically-tp12546.html

Hello Community,

I have a need to submit  flink job to a remote Yarn cluster programatically . I tried to use YarnClusterDescriptor.deploy() , but I get message   RMProxy.java:92:main] - Connecting to ResourceManager at /0.0.0.0:8032.
It is trying to connect the resouce manager on the client machine.  I have set the YARN_CONF_DIR on the client machine  and placed yarn-site.xml , core-site.xml etc.  However it does not seems to be picking these files.

Is this the right way to sumit to a Remote Yarn cluster ?


Thanks,
Jins George