You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2016/07/13 04:36:20 UTC
[08/10] hive git commit: HIVE-14210 : ExecDriver should call
jobclient.close() to trigger cleanup (Thomas Friedrich,
reviewed by Sergey Shelukhin and Vaibhav Gumashta)
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 <se...@apache.org>
Authored: Tue Jul 12 21:24:01 2016 -0700
Committer: Sergey Shelukhin <se...@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 {