[jira] [Created] (FLINK-19171) K8s Resource Manager may lead to resource leak after pod deleted

[Shang Yuanchun (Jira)]

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)