hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ser...@apache.org
Subject [08/10] hive git commit: HIVE-14210 : ExecDriver should call jobclient.close() to trigger cleanup (Thomas Friedrich, reviewed by Sergey Shelukhin and Vaibhav Gumashta)
Date Wed, 13 Jul 2016 04:36:20 GMT
HIVE-14210 : ExecDriver should call jobclient.close() to trigger cleanup (Thomas Friedrich,
reviewed by Sergey Shelukhin and Vaibhav Gumashta)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/8f500f8a
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/8f500f8a
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/8f500f8a

Branch: refs/heads/branch-1
Commit: 8f500f8ad8828a44fede83e6bb7215e89ff58f17
Parents: fbda051
Author: Sergey Shelukhin <sershe@apache.org>
Authored: Tue Jul 12 21:24:01 2016 -0700
Committer: Sergey Shelukhin <sershe@apache.org>
Committed: Tue Jul 12 21:29:11 2016 -0700

----------------------------------------------------------------------
 ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/8f500f8a/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java
index 982ccc7..d5fd849 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java
@@ -211,6 +211,7 @@ public class ExecDriver extends Task<MapredWork> implements Serializable,
Hadoop
     Context ctx = driverContext.getCtx();
     boolean ctxCreated = false;
     Path emptyScratchDir;
+    JobClient jc = null;
 
     MapWork mWork = work.getMapWork();
     ReduceWork rWork = work.getReduceWork();
@@ -391,7 +392,7 @@ public class ExecDriver extends Task<MapredWork> implements Serializable,
Hadoop
         }
       }
 
-      JobClient jc = new JobClient(job);
+      jc = new JobClient(job);
       // make this client wait if job tracker is not behaving well.
       Throttle.checkJobTracker(job, LOG);
 
@@ -454,6 +455,9 @@ public class ExecDriver extends Task<MapredWork> implements Serializable,
Hadoop
           }
           jobID = rj.getID().toString();
         }
+        if (jc!=null) {
+          jc.close();
+        }
       } catch (Exception e) {
 	LOG.warn(e);
       } finally {


Mime
View raw message