diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/GenMapRedUtils.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/GenMapRedUtils.java index acd9bf5..aacf97d 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/GenMapRedUtils.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/GenMapRedUtils.java @@ -1832,6 +1832,12 @@ public static Path createMoveTask(Task currTask, boolean } inputPaths.add(part.getDataLocation()); break; + case DYNAMIC_PARTITION: + for (Partition dynPart:tableScanOp.getConf().getTableMetadata() + .getTableSpec().partitions) { + inputPaths.add(dynPart.getDataLocation()); + } + break; default: assert false; }