diff --git hcatalog/core/src/main/java/org/apache/hive/hcatalog/mapreduce/FileOutputCommitterContainer.java hcatalog/core/src/main/java/org/apache/hive/hcatalog/mapreduce/FileOutputCommitterContainer.java index ad5122d..eae1edd 100644 --- hcatalog/core/src/main/java/org/apache/hive/hcatalog/mapreduce/FileOutputCommitterContainer.java +++ hcatalog/core/src/main/java/org/apache/hive/hcatalog/mapreduce/FileOutputCommitterContainer.java @@ -512,7 +512,7 @@ private void moveTaskOutputs(FileSystem fs, Path file, Path srcDir, final Path finalOutputPath = getFinalPath(fs, file, srcDir, destDir, immutable); FileStatus fileStatus = fs.getFileStatus(file); - if (fileStatus.isFile()) { + if (!fileStatus.isDir()) { if (dryRun){ if (immutable){ // Dryrun checks are meaningless for mutable table - we should always succeed @@ -542,7 +542,7 @@ private void moveTaskOutputs(FileSystem fs, Path file, Path srcDir, } } } - } else if (fileStatus.isDirectory()) { + } else if (fileStatus.isDir()) { FileStatus[] children = fs.listStatus(file); FileStatus firstChild = null; diff --git hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/tool/LaunchMapper.java hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/tool/LaunchMapper.java index 2d1af4b..3edd449 100644 --- hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/tool/LaunchMapper.java +++ hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/tool/LaunchMapper.java @@ -128,7 +128,7 @@ private static void handleHadoopClasspathExtras(Configuration conf, Map