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:18 UTC
[06/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/c323f9a8
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/c323f9a8
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/c323f9a8
Branch: refs/heads/branch-2.1
Commit: c323f9a82b7bb4fc26373492721504a670f8c012
Parents: 09fb8f1
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:24:10 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/c323f9a8/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 8a6499b..a475873 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
@@ -215,6 +215,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();
@@ -394,7 +395,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);
@@ -464,6 +465,9 @@ public class ExecDriver extends Task<MapredWork> implements Serializable, Hadoop
}
jobID = rj.getID().toString();
}
+ if (jc!=null) {
+ jc.close();
+ }
} catch (Exception e) {
LOG.warn("Failed while cleaning up ", e);
} finally {