liu-zhaokun opened a new pull request #8595: [FLINK-12707]Close minicluster will cause memory leak when there are StreamTask closed abnormal URL: https://github.com/apache/flink/pull/8595 [https://issues.apache.org/jira/browse/FLINK-12707](https://issues.apache.org/jira/browse/FLINK-12707) There are several threads in my application,and every thread will launch a flink job with LocalStreamEnvironment/MiniCluster.But when I interrupt these threads again and again, I found there are many residue threads,and that caused a memory leak. When I debug it,this message appears "Recipient[Actorakka://flink/user/taskmanager_0#-584606215] had already been terminated. Sender[null] sent the message of type "org.apache.flink.runtime.rpc.messages.LocalRpcInvocation". So I think when flink close minicluster,TaskExecutor will be closed in the first place,and this operation will cause akka message which will close StreamTask abnormal.So the work thread will be more and more. I call Thread sleep in my application to avoid this problem,any good suggestions?
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
