diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/BucketingSortingReduceSinkOptimizer.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/BucketingSortingReduceSinkOptimizer.java index 7cb0f15..15162d1 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/BucketingSortingReduceSinkOptimizer.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/BucketingSortingReduceSinkOptimizer.java @@ -216,7 +216,7 @@ private boolean checkTable(Table table, private void storeBucketPathMapping(TableScanOperator tsOp, FileStatus[] srcs) { Map bucketFileNameMapping = new HashMap(); for (int pos = 0; pos < srcs.length; pos++) { - if(!srcs[pos].isFile()) { + if(srcs[pos].isDir()) { throw new RuntimeException("Was expecting '" + srcs[pos].getPath() + "' to be bucket file."); } bucketFileNameMapping.put(srcs[pos].getPath().getName(), pos);