diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/NullScanTaskDispatcher.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/NullScanTaskDispatcher.java index 1f21428..90cd41d 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/NullScanTaskDispatcher.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/NullScanTaskDispatcher.java @@ -126,6 +126,10 @@ private void processAlias(MapWork work, HashSet tableScans) { for (TableScanOperator tso : tableScans) { // use LinkedHashMap> // 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);