hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ser...@apache.org
Subject [4/5] hive git commit: HIVE-17479: Staging directories do not get cleaned up for update/delete queries (Jesus Camacho Rodriguez, reviewed by Ashutosh Chauhan, Eugene Koifman) (addendum)
Date Sat, 16 Sep 2017 03:39:32 GMT
HIVE-17479: Staging directories do not get cleaned up for update/delete queries (Jesus Camacho
Rodriguez, reviewed by Ashutosh Chauhan, Eugene Koifman) (addendum)


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

Branch: refs/heads/hive-14535
Commit: d2d9170b42c82e61a11d33ff1fb8aee630d8f0f4
Parents: 3c6d4cb
Author: Jesus Camacho Rodriguez <jcamacho@apache.org>
Authored: Fri Sep 15 16:11:57 2017 -0700
Committer: Jesus Camacho Rodriguez <jcamacho@apache.org>
Committed: Fri Sep 15 17:29:45 2017 -0700

----------------------------------------------------------------------
 .../apache/hadoop/hive/ql/parse/UpdateDeleteSemanticAnalyzer.java  | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/d2d9170b/ql/src/java/org/apache/hadoop/hive/ql/parse/UpdateDeleteSemanticAnalyzer.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/UpdateDeleteSemanticAnalyzer.java
b/ql/src/java/org/apache/hadoop/hive/ql/parse/UpdateDeleteSemanticAnalyzer.java
index 1bca967..702be2e 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/parse/UpdateDeleteSemanticAnalyzer.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/UpdateDeleteSemanticAnalyzer.java
@@ -292,6 +292,8 @@ public class UpdateDeleteSemanticAnalyzer extends SemanticAnalyzer {
     Context rewrittenCtx;
     try {
       rewrittenCtx = new Context(conf);
+      // We keep track of all the contexts that are created by this query
+      // so we can clear them when we finish execution
       ctx.addRewrittenStatementContext(rewrittenCtx);
     } catch (IOException e) {
       throw new SemanticException(ErrorMsg.UPDATEDELETE_IO_ERROR.getMsg());


Mime
View raw message