tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rbalamo...@apache.org
Subject git commit: TEZ-1585. Memory leak in tez session mode (Rajesh Balamohan)
Date Tue, 16 Sep 2014 06:21:41 GMT
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 <rbalamohan@apache.org>
Authored: Tue Sep 16 11:51:13 2014 +0530
Committer: Rajesh Balamohan <rbalamohan@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");


Mime
View raw message