FlinkUI介绍

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

说明

  1. -m yarn -cluster ,在yarn上独立运行的Flink Job;
  2. -yn申请的TaskManager数量;
  3. -yjm 申请的JobManager的内存大小;
  4. -ytm 申请的每个TaskManager的内存大小;
  5. -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版权协议,转载请附上原文出处链接和本声明。