You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by gu...@apache.org on 2014/10/25 07:13:11 UTC
svn commit: r1634177 - in /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql:
optimizer/ConvertJoinMapJoin.java parse/GenTezWork.java
Author: gunther
Date: Sat Oct 25 05:13:11 2014
New Revision: 1634177
URL: http://svn.apache.org/r1634177
Log:
HIVE-8589: TPCDS query 75 fails with tez (Vikram Dixit K via Gunther Hagleitner)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezWork.java
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java?rev=1634177&r1=1634176&r2=1634177&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java Sat Oct 25 05:13:11 2014
@@ -647,7 +647,6 @@ public class ConvertJoinMapJoin implemen
hasDynamicPartitionPruning = true;
break;
}
-
if (op instanceof ReduceSinkOperator || op instanceof FileSinkOperator) {
// crossing reduce sink or file sink means the pruning isn't for this parent.
break;
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezWork.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezWork.java?rev=1634177&r1=1634176&r2=1634177&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezWork.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezWork.java Sat Oct 25 05:13:11 2014
@@ -347,7 +347,8 @@ public class GenTezWork implements NodeP
followingWork = mergeJoinWork;
rWork = (ReduceWork) mergeJoinWork.getMainWork();
} else {
- rWork = (ReduceWork) baseWork;
+ throw new SemanticException("Unknown work type found: "
+ + baseWork.getClass().getCanonicalName());
}
} else {
rWork = (ReduceWork) followingWork;
@@ -402,6 +403,8 @@ public class GenTezWork implements NodeP
} else {
index++;
}
+ } else {
+ index++;
}
}