hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From prasan...@apache.org
Subject hive git commit: HIVE-16086: Fix HiveMetaStoreChecker.checkPartitionDirsSingleThreaded method (Kiran Kumar Kolli reviewed by Prasanth Jayachandran)
Date Fri, 03 Mar 2017 04:49:35 GMT
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 <prasanthj@apache.org>
Authored: Thu Mar 2 20:49:26 2017 -0800
Committer: Prasanth Jayachandran <prasanthj@apache.org>
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()) {


Mime
View raw message