You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2016/05/02 03:14:11 UTC
hive git commit: HIVE-13552 : Templeton job does not write out log
files on InterruptedException (Dennis Chan via Ashutosh Chauhan)
Repository: hive
Updated Branches:
refs/heads/master 805362474 -> b4b821e0a
HIVE-13552 : Templeton job does not write out log files on InterruptedException (Dennis Chan via Ashutosh Chauhan)
Signed-off-by: Ashutosh Chauhan <ha...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/b4b821e0
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/b4b821e0
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/b4b821e0
Branch: refs/heads/master
Commit: b4b821e0acdda7fe4729a5dd9f8655431c90109a
Parents: 8053624
Author: Dennis Chan <ap...@denkc.com>
Authored: Tue Apr 19 14:08:00 2016 -0800
Committer: Ashutosh Chauhan <ha...@apache.org>
Committed: Sun May 1 18:13:10 2016 -0700
----------------------------------------------------------------------
.../org/apache/hive/hcatalog/templeton/ExecServiceImpl.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/b4b821e0/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/ExecServiceImpl.java
----------------------------------------------------------------------
diff --git a/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/ExecServiceImpl.java b/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/ExecServiceImpl.java
index 363541b..e868102 100644
--- a/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/ExecServiceImpl.java
+++ b/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/ExecServiceImpl.java
@@ -213,10 +213,11 @@ public class ExecServiceImpl implements ExecService {
res.exitcode = proc.waitFor();
} catch (InterruptedException e) {
throw new IOException(e);
+ } finally {
+ //flush
+ errorGobbler.out.flush();
+ outputGobbler.out.flush();
}
- //flush
- errorGobbler.out.flush();
- outputGobbler.out.flush();
}
else {
res.exitcode = executor.execute(cmd, execEnv(env));