Re: Submit Flink job programatically

2017-04-07 Thread Kamil Dziublinski
Hey, I had a similar problem when I tried to list the jobs and kill one by name in yarn cluster. Initially I also tried to set YARN_CONF_DIR but it didn't work. What helped tho was passing hadoop conf dir to my application when starting it. Like that: java -cp application.jar:/etc/hadoop/conf Rea

Submit Flink job programatically

2017-04-06 Thread Jins George
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 m