You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Yi Tang (Jira)" <ji...@apache.org> on 2020/09/09 07:30:00 UTC
[jira] [Created] (FLINK-19171) K8s Resource Manager may lead to
resource leak after pod deleted
Yi Tang created FLINK-19171:
-------------------------------
Summary: K8s Resource Manager may lead to resource leak after pod deleted
Key: FLINK-19171
URL: https://issues.apache.org/jira/browse/FLINK-19171
Project: Flink
Issue Type: Bug
Reporter: Yi Tang
{code:java}
private void terminatedPodsInMainThread(List<KubernetesPod> pods) {
getMainThreadExecutor().execute(() -> {
for (KubernetesPod pod : pods) {
if (pod.isTerminated()) {
...
}
}
});
}
{code}
Looks like that the RM only remove the pod from ledger if the pod "isTerminated",
and the pod has been taken accounted after being created.
However, it is not complete by checking pod "isTerminated", e.g. a Pending pod is deleted manually.
Pls let me know if i misunderstand, thanks.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)