liuzhaokun created FLINK-12707:
----------------------------------
Summary: Close minicluster will cause memory leak when there are
StreamTask closed abnormal
Key: FLINK-12707
URL: https://issues.apache.org/jira/browse/FLINK-12707
Project: Flink
Issue Type: Improvement
Components: Runtime / Coordination
Affects Versions: 1.8.0
Reporter: liuzhaokun
Assignee: liuzhaokun
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[Actor[akka://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 message was sent by Atlassian JIRA
(v7.6.3#76005)
