The RemoteEnvironment won’t allow you to spawn a Flink cluster running on Yarn. But you can start one with yarn-session.sh. The same applies to the REST endpoint. You first have to start a cluster.
Cheers, Till On Fri, Jul 28, 2017 at 12:14 PM, 程骥 <ji_ch...@qq.com> wrote: > Hi, > Thanks for yor help. > This is a good idea. > Maybe I didn't understand the information of restful API. > I think the restful API can not submit a job to yarn. > Is that right? > > > > ------------------ 原始邮件 ------------------ > *发件人:* "z...@zjdex.com";<z...@zjdex.com>; > *发送时间:* 2017年7月28日(星期五) 下午5:15 > *收件人:* "程骥"<ji_ch...@qq.com>; "user"<user@flink.apache.org>; > *主题:* re: How can I submit a flink job to YARN/Cluster from java code? > > Hi: > I think you can use Flink restful API, like "POST: > /jars/MyProgram.jar/run?savepointPath=/my-savepoints/ > savepoint-1bae02a80464&allowNonRestoredState=true" > The detail information of restful API , you can see the link > https://ci.apache.org/projects/flink/flink-docs- > release-1.3/monitoring/rest_api.html . > > ------------------------------ > z...@zjdex.com > > > *发件人:* 程骥 <ji_ch...@qq.com> > *发送时间:* 2017-07-28 15:50 > *收件人:* user <user@flink.apache.org> > *主题:* How can I submit a flink job to YARN/Cluster from java code? > Hello, > I want to submit a flink job to YARN/Cluster from java code.If this is > feasible? > Is there anyone tried to do it before ? > > > Thanks > >