You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by rb...@apache.org on 2014/09/16 08:21:41 UTC
git commit: TEZ-1585. Memory leak in tez session mode (Rajesh
Balamohan)
Repository: tez
Updated Branches:
refs/heads/master dbe6a38a5 -> 938097d85
TEZ-1585. Memory leak in tez session mode (Rajesh Balamohan)
Project: http://git-wip-us.apache.org/repos/asf/tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/938097d8
Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/938097d8
Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/938097d8
Branch: refs/heads/master
Commit: 938097d85f6f943a399c16fa50f07a7e2b05bdb5
Parents: dbe6a38
Author: Rajesh Balamohan <rb...@apache.org>
Authored: Tue Sep 16 11:51:13 2014 +0530
Committer: Rajesh Balamohan <rb...@apache.org>
Committed: Tue Sep 16 11:51:13 2014 +0530
----------------------------------------------------------------------
.../src/main/java/org/apache/tez/dag/app/DAGAppMaster.java | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tez/blob/938097d8/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java b/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java
index ea0ab3b..0e4f78b 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java
@@ -536,6 +536,13 @@ public class DAGAppMaster extends AbstractService {
}
}
}
+ //close all fs related caches
+ try {
+ FileSystem.closeAllForUGI(context.getCurrentDAG().getDagUGI());
+ } catch (IOException e) {
+ LOG.warn("Error occurred when trying to close FileSystem for userName " + context
+ .getCurrentDAG().getDagUGI().getUserName(), e);
+ }
break;
case AM_REBOOT:
LOG.info("Received an AM_REBOOT signal");