You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2014/10/13 03:28:43 UTC
git commit: HBASE-12235 Backport to 0.94: HBASE-9002
TestDistributedLogSplitting.testRecoverdEdits should test correct region
(Sean Busbey)
Repository: hbase
Updated Branches:
refs/heads/0.94 958edae67 -> 45eb18ba5
HBASE-12235 Backport to 0.94: HBASE-9002 TestDistributedLogSplitting.testRecoverdEdits should test correct region (Sean Busbey)
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/45eb18ba
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/45eb18ba
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/45eb18ba
Branch: refs/heads/0.94
Commit: 45eb18ba5eda6c66e0b53377b9722b062cd3ee3c
Parents: 958edae
Author: stack <st...@apache.org>
Authored: Sun Oct 12 18:28:32 2014 -0700
Committer: stack <st...@apache.org>
Committed: Sun Oct 12 18:28:32 2014 -0700
----------------------------------------------------------------------
.../hadoop/hbase/master/TestDistributedLogSplitting.java | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/45eb18ba/src/test/java/org/apache/hadoop/hbase/master/TestDistributedLogSplitting.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/hadoop/hbase/master/TestDistributedLogSplitting.java b/src/test/java/org/apache/hadoop/hbase/master/TestDistributedLogSplitting.java
index d4237fc..51e4eba 100644
--- a/src/test/java/org/apache/hadoop/hbase/master/TestDistributedLogSplitting.java
+++ b/src/test/java/org/apache/hadoop/hbase/master/TestDistributedLogSplitting.java
@@ -226,9 +226,16 @@ public class TestDistributedLogSplitting {
List<HRegionInfo> regions = null;
HRegionServer hrs = null;
for (int i = 0; i < NUM_RS; i++) {
+ boolean foundRS = false;
hrs = rsts.get(i).getRegionServer();
regions = hrs.getOnlineRegions();
- if (regions.size() != 0) break;
+ for (HRegionInfo region : regions) {
+ if (region.getTableNameAsString().equalsIgnoreCase("table")) {
+ foundRS = true;
+ break;
+ }
+ }
+ if (foundRS) break;
}
final Path logDir = new Path(rootdir, HLog.getHLogDirectoryName(hrs
.getServerName().toString()));