??????re: How can I submit a flink job to YARN/Cluster from java code?

2017-07-31 Thread ????
ok,thank you. -- -- ??: "z...@zjdex.com";; : 2017??7??31??(??) 9:31 ??: ""; "user"; : re: How can I submit a flink job to YARN/Cluster from java code? You can see the detail informa

re: How can I submit a flink job to YARN/Cluster from java code?

2017-07-30 Thread z...@zjdex.com
18:14 z...@zjdex.com; user ?? ??re: How can I submit a flink job to YARN/Cluster from java code? 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

Re: re: How can I submit a flink job to YARN/Cluster from java code?

2017-07-28 Thread Till Rohrmann
(星期五) 下午5:15 > *收件人:* "程骥"; "user"; > *主题:* 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-1bae02a80

??????re: How can I submit a flink job to YARN/Cluster from java code?

2017-07-28 Thread ????
?) 5:15 ??: "????"; "user"; ????: 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&allowNonRestoredStat

re: How can I submit a flink job to YARN/Cluster from java code?

2017-07-28 Thread z...@zjdex.com
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/monitorin

Re: How can I submit a flink job to YARN/Cluster from java code?

2017-07-28 Thread Till Rohrmann
Hi, it is possible to submit a job to a running cluster (Standalone/Mesos/Yarn) by using the RemoteEnvironment which you can create via ExecutionEnvironment.createRemoteEnvironment and then executing your program (e.g. running it in the IDE). This assumes that the remote cluster is already running