diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/MetadataOnlyOptimizer.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/MetadataOnlyOptimizer.java index 15653bf..dc7ae6a 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/MetadataOnlyOptimizer.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/MetadataOnlyOptimizer.java @@ -247,12 +247,6 @@ private String encode(Map partSpec) { return partSpec.toString().replaceAll("[:/#\\?]", "_"); } - private void convertToMetadataOnlyQuery(MapredWork work, - TableScanOperator tso) { - String alias = getAliasForTableScanOperator(work, tso); - processAlias(work, alias); - } - @Override public Object dispatch(Node nd, Stack stack, Object... nodeOutputs) throws SemanticException { @@ -305,8 +299,10 @@ public Object dispatch(Node nd, Stack stack, Object... nodeOutputs) while (iterator.hasNext()) { TableScanOperator tso = iterator.next(); - LOG.info("Metadata only table scan for " + tso.getConf().getAlias()); - convertToMetadataOnlyQuery((MapredWork) task.getWork(), tso); + MapredWork work = (MapredWork) task.getWork(); + String alias = getAliasForTableScanOperator(work, tso); + LOG.info("Metadata only table scan for " + alias); + processAlias(work, alias); } return null;