Repository: hive
Updated Branches:
  refs/heads/master 44bcedbad -> 348b8ec27


HIVE-14411 : selecting Hive on Hbase table may cause FileNotFoundException 
(Niklaus Xiao via Ashutosh Chauhan)

Signed-off-by: Ashutosh Chauhan <[email protected]>


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/348b8ec2
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/348b8ec2
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/348b8ec2

Branch: refs/heads/master
Commit: 348b8ec27c86b1f1674945d7cdfed81dade2690c
Parents: 44bcedb
Author: niklaus xiao <[email protected]>
Authored: Thu Aug 4 18:54:46 2016 -0700
Committer: Ashutosh Chauhan <[email protected]>
Committed: Thu Aug 4 18:54:46 2016 -0700

----------------------------------------------------------------------
 .../hive/ql/optimizer/physical/NullScanTaskDispatcher.java       | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/348b8ec2/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/NullScanTaskDispatcher.java
----------------------------------------------------------------------
diff --git 
a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/NullScanTaskDispatcher.java
 
b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/NullScanTaskDispatcher.java
index 1f21428..90cd41d 100644
--- 
a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/NullScanTaskDispatcher.java
+++ 
b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/NullScanTaskDispatcher.java
@@ -126,6 +126,10 @@ public class NullScanTaskDispatcher implements Dispatcher {
     for (TableScanOperator tso : tableScans) {
       // use LinkedHashMap<String, Operator<? extends OperatorDesc>>
       // getAliasToWork()
+         // should not apply this for non-native table
+      if (tso.getConf().getTableMetadata().getStorageHandler() != null) {
+        continue;
+      }
       String alias = getAliasForTableScanOperator(work, tso);
       aliases.add(alias);
       tso.getConf().setIsMetadataOnly(true);

Reply via email to