Apache/hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-9639. DecommissioningNodesWatcher cause memory leak. Contributed by Bilwa S T.

Browse Source 
(cherry picked from commit be80334cdf255616f589217726483194fb56dcc6)
This commit is contained in:
bibinchundatt 2019-06-27 09:59:44 +05:30
parent 1bae5c7024
commit 4f622ecad8
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/DecommissioningNodesWatcher.java
View File

@ -207,6 +207,11 @@ public synchronized void remove(NodeId nodeId) {
}
}
public void stop() {
pollTimer.cancel();
pollTimer = null;
}
/**
* Status about a specific decommissioning node.
*

1
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceTrackerService.java
View File

@ -260,6 +260,7 @@ protected void serviceStart() throws Exception {
@Override
protected void serviceStop() throws Exception {
decommissioningWatcher.stop();
if (this.server != null) {
this.server.stop();
}