1.概述
flink程序运行起来,需要获取flink的任务状态,我们有几种方式获取。
- 使用yarn命令或者,查看任务状态
- 使用flink指标监控查看flink任务状态
- 使用JobListener监听任务状态
下面我们来主要介绍如何使用JobListener监听任务状态。
2.使用
JobListener的使用很简单,我们只需要继承他,然后实现我们自己的类,然后提交任务的时候注册就好了。
import java.util.concurrent.CompletableFuture;
import java.util
标签:状态,JobListener,flink,Flink,任务,使用,监听
From: https://blog.csdn.net/qq_21383435/article/details/131528104