execution.job-listeners 只可以设置 JobListener 的实现。

需求场景应该使用 JobStatusListener

Best,
TonyChen

> 2022年11月24日 11:55,casel.chen <casel_c...@126.com> 写道:
> 
> 可以使用 execution.job-listeners 参数吗?这个参数的用法是怎样的?
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 
> 在 2022-11-24 10:41:35,"Yang Wang" <danrtsey...@gmail.com> 写道:
>> 其实可以参考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可以进行注册的方法呢?

回复