如何用代码方式在yarn上运行flink的jar包

Question

目前在项目中是使用代码方式，发生一个http请求，http://flink:8082/jars/xx.jar/run 提交任务在单节点的flink上运行。
现在需要在yarn上运行jar包，如何通过代码方式来实现？

Answer 1

Michael_PK 2021-01-28 19:59:50

没太明白你的意思，详细描述下。

你的意思是：做成一个服务，然后一个请求发送过去，就让去开始执行？

• 提问者 慕仔7067995 #1

  目前在做一个实时标签项目，通过flink对接kafka数据流进行处理，得到符合条件的客户信息...  实时标签可以随时启停，启动实时标签就是提交一个flink任务。
  flink任务即是执行jar包，启动不同实时标签传入的参数不一样。
  目前是通过发送一个post请求 http://flinkip:8082/jars/xx.jar/run 提交任务在单节点的flink上运行，参数放在body里面。
  现在需要提交任务到yarn上运行，我知道命令行的启动指令，但是这里能通过发送类似http请求的方式启动吗？

• Michael_PK 回复 提问者 慕仔7067995 #2

  提交请求可以是可以，但是这似乎违背了实时流处理的根本原则了吧，实时的是一直处理呢。
  
  你真要这么做，那就只能是开发一个server，在server中运行flink，然后发送一个http请求发起去触发