你的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/
