diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java index d801ae7372..a5a56ea5d6 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/MapOperator.java @@ -346,6 +346,9 @@ else if (partRawRowObjectInspector.equals(tblRawRowObjectInspector)) { } String tableName = conf.getPathToPartitionInfo().get(e.getKey()).getTableName(); + if (tableNameToConf.containsKey(tableName)) { + continue; + } for (String alias: aliases) { Operator rootOp = conf.getAliasToWork().get(alias); if (!(rootOp instanceof TableScanOperator)) {