[ 
https://issues.apache.org/jira/browse/FLINK-18228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Yang Wang closed FLINK-18228.
-----------------------------
    Resolution: Duplicate

> Release pending pods/containers timely when pending slots changed
> -----------------------------------------------------------------
>
>                 Key: FLINK-18228
>                 URL: https://issues.apache.org/jira/browse/FLINK-18228
>             Project: Flink
>          Issue Type: Improvement
>          Components: Deployment / Kubernetes, Deployment / YARN, Runtime / 
> Coordination
>    Affects Versions: 1.12.0
>            Reporter: Yang Wang
>            Priority: Major
>
> Currently, when we deploy a session cluster on Yarn/K8s and submit a job into 
> the existing cluster, some pending pods/containers may be created due to no 
> enough resource. Even the job will fail with slot allocation timeout or be 
> canceled, the pending pods/containers will still be there. Until allocated 
> and launched, they could be released via TaskManager idle timeout.
>  
> This behavior how to release the pending pods/containers could be improved. 
> Once the pending slots changed in the {{SlotManager}}, it could notify the 
> {{ActiveResourceManager}} to do some corresponding actions(e.g. release the 
> needless pending pods). This will help a lot when the cluster is small and do 
> not have too much available resources.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to