Repository: hive Updated Branches: refs/heads/master 93db527f4 -> b62246540
HIVE-16086: Fix HiveMetaStoreChecker.checkPartitionDirsSingleThreaded method (Kiran Kumar Kolli reviewed by Prasanth Jayachandran) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/b6224654 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/b6224654 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/b6224654 Branch: refs/heads/master Commit: b62246540d604bbb0343e2dc1cec7411e60eacd9 Parents: 93db527 Author: Prasanth Jayachandran <[email protected]> Authored: Thu Mar 2 20:49:26 2017 -0800 Committer: Prasanth Jayachandran <[email protected]> Committed: Thu Mar 2 20:49:26 2017 -0800 ---------------------------------------------------------------------- .../org/apache/hadoop/hive/ql/metadata/HiveMetaStoreChecker.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/b6224654/ql/src/java/org/apache/hadoop/hive/ql/metadata/HiveMetaStoreChecker.java ---------------------------------------------------------------------- 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 @@ public class HiveMetaStoreChecker { */ private void checkPartitionDirsSingleThreaded(Queue<Path> basePaths, final Set<Path> allDirs, final FileSystem fs, final int depth, final int maxDepth) throws IOException, HiveException { - final Queue<Path> nextLevel = new LinkedList<>(); for (final Path path : basePaths) { FileStatus[] statuses = fs.listStatus(path, FileUtils.HIDDEN_FILES_PATH_FILTER); + final Queue<Path> nextLevel = new LinkedList<>(); boolean fileFound = false; for (FileStatus status : statuses) { if (status.isDirectory()) {
