tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rbalamo...@apache.org
Subject [1/3] git commit: TEZ-1585. Memory leak in tez session mode (Rajesh Balamohan) (cherry picked from commit 938097d85f6f943a399c16fa50f07a7e2b05bdb5)
Date Tue, 16 Sep 2014 06:41:27 GMT
Repository: tez
Updated Branches:
  refs/heads/branch-0.5 f83387931 -> 915999a14
  refs/heads/master 938097d85 -> 3b34c4182


TEZ-1585. Memory leak in tez session mode (Rajesh Balamohan)
(cherry picked from commit 938097d85f6f943a399c16fa50f07a7e2b05bdb5)


Project: http://git-wip-us.apache.org/repos/asf/tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/59c0462a
Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/59c0462a
Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/59c0462a

Branch: refs/heads/branch-0.5
Commit: 59c0462aa851d30eae934075314a4ad18ae99a88
Parents: f833879
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 12:05:47 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/59c0462a/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 9cd716a..a576e79 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
@@ -531,6 +531,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