You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by te...@apache.org on 2016/08/12 01:00:11 UTC
hbase git commit: HBASE-16400 TestHBaseFsck fails on
HBase-0.98-on-Hadoop-1.1 build
Repository: hbase
Updated Branches:
refs/heads/0.98 c31627efc -> 510d11769
HBASE-16400 TestHBaseFsck fails on HBase-0.98-on-Hadoop-1.1 build
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/510d1176
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/510d1176
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/510d1176
Branch: refs/heads/0.98
Commit: 510d1176907706ae35ce1b0a6a1b94fbd9023a4d
Parents: c31627e
Author: tedyu <yu...@gmail.com>
Authored: Thu Aug 11 18:00:03 2016 -0700
Committer: tedyu <yu...@gmail.com>
Committed: Thu Aug 11 18:00:03 2016 -0700
----------------------------------------------------------------------
.../org/apache/hadoop/hbase/util/hbck/HFileCorruptionChecker.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/510d1176/hbase-server/src/main/java/org/apache/hadoop/hbase/util/hbck/HFileCorruptionChecker.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/hbck/HFileCorruptionChecker.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/hbck/HFileCorruptionChecker.java
index db700c8..707b845 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/hbck/HFileCorruptionChecker.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/hbck/HFileCorruptionChecker.java
@@ -198,7 +198,7 @@ public class HFileCorruptionChecker {
List<FileStatus> cfs = FSUtils.filterFileStatuses(statuses, new FamilyDirFilter(fs));
// Hadoop 1.0 listStatus does not throw an exception if the path does not exist.
- if (cfs.size() == 0 && !fs.exists(regionDir)) {
+ if ((cfs == null || cfs.size() == 0) && !fs.exists(regionDir)) {
LOG.warn("Region Directory " + regionDir +
" does not exist. Likely due to concurrent split/compaction. Skipping.");
missing.add(regionDir);