其实可以参考Flink Kubernetes Operator里面的做法,设置execution.shutdown-on-application-finish参数为false 然后通过轮询Flink RestAPI拿到job的状态,job结束了再主动停掉Application cluster
Best, Yang JasonLee <17610775...@163.com> 于2022年11月24日周四 09:59写道: > Hi > > > 可以通过 Flink 的 Metric 和 Yarn 的 Api 去获取任务的状态(任务提交到 yarn 的话) > > > Best > JasonLee > > > ---- 回复的原邮件 ---- > | 发件人 | casel.chen<casel_c...@126.com> | > | 发送日期 | 2022年11月23日 08:32 | > | 收件人 | user-zh@flink.apache.org<user-zh@flink.apache.org> | > | 主题 | flink作业提交运行后如何监听作业状态发生变化? | > > 请问flink作业提交运行后如何监听作业状态发生变化以便在控台上实时显示作业状态变更?目前我们的做法是轮询,但效率低,有没有listener可以进行注册的方法呢?