This is an automated email from the ASF dual-hosted git repository.
sankarh pushed a commit to branch branch-3
in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/branch-3 by this push:
new 220ca4d901c HIVE-27612: Backport of HIVE-22169: Tez: SplitGenerator
tries to look for plan files which won't exist for Tez (Gopal V via Vineet Garg)
220ca4d901c is described below
commit 220ca4d901c76be62d71f478b20c1eadcbaf6052
Author: Aman Raj <[email protected]>
AuthorDate: Mon Aug 28 14:15:16 2023 +0530
HIVE-27612: Backport of HIVE-22169: Tez: SplitGenerator tries to look for
plan files which won't exist for Tez (Gopal V via Vineet Garg)
Signed-off-by: Sankar Hariappan <[email protected]>
Closes (#4591)
---
.../java/org/apache/hadoop/hive/ql/exec/Utilities.java | 16 +++++++++-------
1 file changed, 9 insertions(+), 7 deletions(-)
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java
b/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java
index ee9150fe725..abac436e56a 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java
@@ -298,15 +298,17 @@ public final class Utilities {
return;
}
+
try {
- FileSystem fs = mapPath.getFileSystem(conf);
- if (fs.exists(mapPath)) {
- fs.delete(mapPath, true);
- }
- if (fs.exists(reducePath)) {
- fs.delete(reducePath, true);
+ if (!HiveConf.getBoolVar(conf, ConfVars.HIVE_RPC_QUERY_PLAN)) {
+ FileSystem fs = mapPath.getFileSystem(conf);
+ if (fs.exists(mapPath)) {
+ fs.delete(mapPath, true);
+ }
+ if (fs.exists(reducePath)) {
+ fs.delete(reducePath, true);
+ }
}
-
} catch (Exception e) {
LOG.warn("Failed to clean-up tmp directories.", e);
} finally {
