如何通过复位API“运行纱线单弗林克工作”？

Question

从我们知道我们可以通过下面的命令“纱线运行单个弗林克工作”的弗林克正式文件，我的问题是可以通过我们的REST API“运行纱线单弗林克工作”，并得到了应用程序的API？

./bin/flink run -m yarn-cluster -yn 2 ./examples/batch/WordCount.jar

Answer 1

见（有点欺骗性命名）Monitoring REST API。您可以使用/jars/upload请求您（脂肪/尤伯杯）的容器发送到集群。这返回一个ID，就可以与/jars/:jarid/run请求，用来启动你的工作。

如果您还需要启动集群，那么你目前（据我所知）将需要编写一些Java代码来开始纱线集群。有在弗林克两个源文件做同样的事情：

• ProgramDeployer.java由弗林克表API使用。
• CliFrontEnd.java通过命令行工具使用。