你的Flink任务应该是用attach的方式起的,也就是没有加-d,这种情况在1.10之前起的任务本质上是一个session,
只有当结果被client端retrieve走以后,才会退出,如果client挂了或者你主动停掉了,那就会留下一个空的session

你可以通过如下log确认起的session模式

2020-08-04 10:45:36,868 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -
Starting YarnSessionClusterEntrypoint (Version: 1.9.1, Rev:f23f82a,
Date:01.11.2019 @ 11:20:33 CST)


你可以flink run -d ...就是perjob模式了,或者升级到1.10及以后版本attach/detach都是真正的perjob


Best,
Yang

bradyMk <[email protected]> 于2020年8月4日周二 下午8:04写道:

> 您好:
> 请问这是flink这个版本自身的bug么?那就意味着没有办法解决了吧,只能手动kill掉?
>
>
>
> -----
> Best Wishes
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

回复