diff --git a/ql/src/java/org/apache/hadoop/hive/ql/metadata/HiveMetaStoreChecker.java b/ql/src/java/org/apache/hadoop/hive/ql/metadata/HiveMetaStoreChecker.java index 0859022..3420ef8 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/metadata/HiveMetaStoreChecker.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/metadata/HiveMetaStoreChecker.java @@ -558,9 +558,9 @@ private void checkPartitionDirsInParallel(final ThreadPoolExecutor pool, */ private void checkPartitionDirsSingleThreaded(Queue basePaths, final Set allDirs, final FileSystem fs, final int depth, final int maxDepth) throws IOException, HiveException { - final Queue nextLevel = new LinkedList<>(); for (final Path path : basePaths) { FileStatus[] statuses = fs.listStatus(path, FileUtils.HIDDEN_FILES_PATH_FILTER); + final Queue nextLevel = new LinkedList<>(); boolean fileFound = false; for (FileStatus status : statuses) { if (status.isDirectory()) {