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 0d80ed3c82..a453449045 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 @@ -544,6 +544,7 @@ private ReparseResult parseRewrittenQuery(StringBuilder rewrittenQueryStr, Strin Context rewrittenCtx; try { rewrittenCtx = new Context(conf); + rewrittenCtx.setHDFSCleanup(true); // 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);