svn commit: r1655927 - /hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java

[xuefu]

Author: xuefu
Date: Fri Jan 30 03:29:26 2015
New Revision: 1655927

URL: http://svn.apache.org/r1655927
Log:
HIVE-9515: Check hive.vectorized.execution.reduce.enabled [Spark Branch] (Jimmy 
via Xuefu)

Modified:
    
hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java

Modified: 
hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java
URL: 
http://svn.apache.org/viewvc/hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java?rev=1655927&r1=1655926&r2=1655927&view=diff
==============================================================================
--- 
hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java
 (original)
+++ 
hive/branches/spark/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java
 Fri Jan 30 03:29:26 2015
@@ -318,7 +318,9 @@ public class Vectorizer implements Physi
         for (BaseWork baseWork : sparkWork.getAllWork()) {
           if (baseWork instanceof MapWork) {
             convertMapWork((MapWork) baseWork, false);
-          } else if (baseWork instanceof ReduceWork) {
+          } else if (baseWork instanceof ReduceWork
+              && HiveConf.getBoolVar(pctx.getConf(),
+                  HiveConf.ConfVars.HIVE_VECTORIZATION_REDUCE_ENABLED)) {
             convertReduceWork((ReduceWork) baseWork);
           }
         }