Yarn
flink run -m yarn-cluster -yn 4 -yjm 1024 -ytm 1024 -c com.zx.main.LmLoan /home/code/flink-report/flinksql/target/flinksql-1.0-SNAPSHOT-jar-with-dependencies.jar
说明
- -m yarn -cluster ,在yarn上独立运行的Flink Job;
- -yn申请的TaskManager数量;
- -yjm 申请的JobManager的内存大小;
- -ytm 申请的每个TaskManager的内存大小;
- -c 类名;
Flink UI
说明:taskmanager.numberOfTaskSlots :1
所以可以槽数为0。
TaskManager
TaskManager所在的机器上
TM的进程
JobManager
JM所在机器的位置
Submit New Job
对于独立模式和yarn-session模式,可以通过此ui操作来提交任务。对于独立job的flink只能通过命令。
背压
查看背压:当DAG的某个过程的背压状态为 low 或者 high 时,则说明下游的处理速度不及上游的输出速度。也就是说 下游的处理是整个任务的瓶颈所在,需要进行优化处理
版权声明:本文为weixin_45480444原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。