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 5f6f401e311..09619776c5d 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 @@ -2636,7 +2636,7 @@ public static void setAcidVersionInDataFile(Writer writer) { */ public static void writeVersionFile(Path deltaOrBaseDir, FileSystem fs) throws IOException { Path formatFile = getVersionFilePath(deltaOrBaseDir); - if(!fs.exists(formatFile)) { + if(!fs.isFile(formatFile)) { try (FSDataOutputStream strm = fs.create(formatFile, false)) { strm.write(UTF8.encode(String.valueOf(ORC_ACID_VERSION)).array()); } catch (IOException ioe) {