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

来源:9-6 Flink on YARN两种方式

慕仔7067995

2021-01-28

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

写回答

1回答

Michael_PK

2021-01-28

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


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

0
2
Michael_PK
回复
慕仔7067995
提交请求可以是可以,但是这似乎违背了实时流处理的根本原则了吧,实时的是一直处理呢。 你真要这么做,那就只能是开发一个server,在server中运行flink,然后发送一个http请求发起去触发
2021-01-28
共2条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink

969 学习 · 296 问题

查看课程