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 c0e3b25001fc..909b22cf8a47 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 @@ -1558,6 +1558,10 @@ public static Map getHdfsDirSnapshots(final FileSystem fs FileStatus fStatus = itr.next(); Path fPath = fStatus.getPath(); if (fStatus.isDirectory()) { + if (baseFileFilter.accept(fPath) || deltaFileFilter.accept(fPath) + || deleteEventDeltaDirFilter.accept(fPath)) { + addToSnapshot(dirToSnapshots, fPath); + } stack.push(FileUtils.listStatusIterator(fs, fPath, acidHiddenFileFilter)); } else { Path parentDirPath = fPath.getParent();