HIVE-6091 : Empty pipeout files are created for connection create/close (Thiruvel Thirumoolan, Bing Li via Ashutosh Chauhan)
Signed-off-by: Ashutosh Chauhan <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/6e8eeb74 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/6e8eeb74 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/6e8eeb74 Branch: refs/heads/beeline-cli Commit: 6e8eeb7439d44b2e37f70a77f2abc27d59ef8993 Parents: 7cfe374 Author: Thiruvel Thirumoolan <[email protected]> Authored: Fri Dec 20 14:09:00 2013 -0800 Committer: Ashutosh Chauhan <[email protected]> Committed: Wed Sep 23 08:34:21 2015 -0700 ---------------------------------------------------------------------- ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/6e8eeb74/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java b/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java index 5f528167..014941e 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java @@ -677,6 +677,9 @@ public class SessionState { if (localSessionPath != null) { FileSystem.getLocal(conf).delete(localSessionPath, true); } + if (this.getTmpOutputFile().exists()) { + this.getTmpOutputFile().delete(); + } } /**
