You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2013/11/20 04:24:17 UTC
svn commit: r1543705 -
/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java
Author: hashutosh
Date: Wed Nov 20 03:24:16 2013
New Revision: 1543705
URL: http://svn.apache.org/r1543705
Log:
HIVE-5846 : Analyze command fails with vectorization on (Remus Rusanu via Ashutosh Chauhan)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java?rev=1543705&r1=1543704&r2=1543705&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java Wed Nov 20 03:24:16 2013
@@ -450,8 +450,10 @@ public class Vectorizer implements Physi
case REDUCESINK:
ret = validateReduceSinkOperator((ReduceSinkOperator) op);
break;
- case FILESINK:
case TABLESCAN:
+ ret = validateTableScanOperator((TableScanOperator) op);
+ break;
+ case FILESINK:
case LIMIT:
ret = true;
break;
@@ -462,6 +464,11 @@ public class Vectorizer implements Physi
return ret;
}
+ private boolean validateTableScanOperator(TableScanOperator op) {
+ TableScanDesc desc = op.getConf();
+ return !desc.isGatherStats();
+ }
+
private boolean validateMapJoinOperator(MapJoinOperator op) {
MapJoinDesc desc = op.getConf();
byte posBigTable = (byte) desc.getPosBigTable();