hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gunt...@apache.org
Subject svn commit: r1539573 - in /hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/mr: ExecMapper.java ExecReducer.java
Date Thu, 07 Nov 2013 09:39:59 GMT
Author: gunther
Date: Thu Nov  7 09:39:58 2013
New Revision: 1539573

URL: http://svn.apache.org/r1539573
Log:
HIVE-5738: Need to clear global work in ExecMapper/ExecReducer for container reuse in tez
(Gunther Hagleitner)

Modified:
    hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecMapper.java
    hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecReducer.java

Modified: hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecMapper.java
URL: http://svn.apache.org/viewvc/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecMapper.java?rev=1539573&r1=1539572&r2=1539573&view=diff
==============================================================================
--- hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecMapper.java (original)
+++ hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecMapper.java Thu Nov
 7 09:39:58 2013
@@ -258,6 +258,7 @@ public class ExecMapper extends MapReduc
       }
     } finally {
       MapredContext.close();
+      Utilities.clearWorkMap();
     }
   }
 

Modified: hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecReducer.java
URL: http://svn.apache.org/viewvc/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecReducer.java?rev=1539573&r1=1539572&r2=1539573&view=diff
==============================================================================
--- hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecReducer.java (original)
+++ hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecReducer.java Thu Nov
 7 09:39:58 2013
@@ -326,6 +326,7 @@ public class ExecReducer extends MapRedu
       }
     } finally {
       MapredContext.close();
+      Utilities.clearWorkMap();
     }
   }
 }



Mime
View raw message