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 2013/10/25 07:20:40 UTC

svn commit: r1535640 - /hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java

Author: gunther
Date: Fri Oct 25 05:20:40 2013
New Revision: 1535640

URL: http://svn.apache.org/r1535640
Log:
HIVE-5651: union_view.q is failing on tez branch (Gunther Hagleitner)

Modified:
    hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java

Modified: hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java
URL: http://svn.apache.org/viewvc/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java?rev=1535640&r1=1535639&r2=1535640&view=diff
==============================================================================
--- hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java (original)
+++ hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java Fri Oct 25 05:20:40 2013
@@ -260,7 +260,9 @@ public class HiveInputFormat<K extends W
 
     Utilities.copyTableJobPropertiesToConf(table, conf);
 
-    pushFilters(conf, tableScan);
+    if (tableScan != null) {
+      pushFilters(conf, tableScan);
+    }
 
     FileInputFormat.setInputPaths(conf, dirs.toArray(new Path[dirs.size()]));
     conf.setInputFormat(inputFormat.getClass());
@@ -300,7 +302,7 @@ public class HiveInputFormat<K extends W
       // Make filter pushdown information available to getSplits.
       if ((aliases != null) && (aliases.size() == 1)) {
         Operator op = mrwork.getAliasToWork().get(aliases.get(0));
-        if ((op != null) && (op instanceof TableScanOperator)) {
+        if (op instanceof TableScanOperator) {
           tableScan = (TableScanOperator) op;
         }
       }