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 时，则说明下游的处理速度不及上游的输出速度。也就是说 下游的处理是整个任务的瓶颈所在，需要进行优化处理