diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/AcidUtils.java b/ql/src/java/org/apache/hadoop/hive/ql/io/AcidUtils.java index f207bf2fdb..7c21ff71de 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/AcidUtils.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/AcidUtils.java @@ -21,6 +21,7 @@ import static org.apache.hadoop.hive.ql.exec.Utilities.COPY_KEYWORD; import static org.apache.hadoop.hive.ql.exec.AbstractFileMergeOperator.UNION_SUDBIR_PREFIX; +import java.io.FileNotFoundException; import java.io.IOException; import java.io.Serializable; import java.net.URI; @@ -2403,7 +2404,12 @@ private static Path chooseFile(Path baseOrDeltaDir, FileSystem fs) throws IOExce baseOrDeltaDir.getName().startsWith(DELTA_PREFIX))) { throw new IllegalArgumentException(baseOrDeltaDir + " is not a base/delta"); } - FileStatus[] dataFiles = fs.listStatus(new Path[] {baseOrDeltaDir}, originalBucketFilter); + FileStatus[] dataFiles; + try { + dataFiles = fs.listStatus(new Path[]{baseOrDeltaDir}, originalBucketFilter); + } catch (FileNotFoundException e) { + dataFiles = null; + } return dataFiles != null && dataFiles.length > 0 ? dataFiles[0].getPath() : null; }