svn commit: r1202309 - in /hbase/branches/0.92: CHANGES.txt src/test/java/org/apache/hadoop/hbase/master/TestDistributedLogSplitting.java

[tedyu]

Author: tedyu
Date: Tue Nov 15 17:13:33 2011
New Revision: 1202309

URL: http://svn.apache.org/viewvc?rev=1202309&view=rev
Log:
HBASE-4790  Occasional TestDistributedLogSplitting failure (Jinchao)

Modified:
    hbase/branches/0.92/CHANGES.txt
    
hbase/branches/0.92/src/test/java/org/apache/hadoop/hbase/master/TestDistributedLogSplitting.java

Modified: hbase/branches/0.92/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/hbase/branches/0.92/CHANGES.txt?rev=1202309&r1=1202308&r2=1202309&view=diff
==============================================================================
--- hbase/branches/0.92/CHANGES.txt (original)
+++ hbase/branches/0.92/CHANGES.txt Tue Nov 15 17:13:33 2011
@@ -438,6 +438,7 @@ Release 0.92.0 - Unreleased
    HBASE-4690  Intermittent TestRegionServerCoprocessorExceptionWithAbort 
failure
    HBASE-4518  TestServerCustomProtocol fails intermittently
    HBASE-4778  Don't ignore corrupt StoreFiles when opening a region
+   HBASE-4790  Occasional TestDistributedLogSplitting failure (Jinchao)
 
   IMPROVEMENTS
    HBASE-3290  Max Compaction Size (Nicolas Spiegelberg via Stack)  

Modified: 
hbase/branches/0.92/src/test/java/org/apache/hadoop/hbase/master/TestDistributedLogSplitting.java
URL: 
http://svn.apache.org/viewvc/hbase/branches/0.92/src/test/java/org/apache/hadoop/hbase/master/TestDistributedLogSplitting.java?rev=1202309&r1=1202308&r2=1202309&view=diff
==============================================================================
--- 
hbase/branches/0.92/src/test/java/org/apache/hadoop/hbase/master/TestDistributedLogSplitting.java
 (original)
+++ 
hbase/branches/0.92/src/test/java/org/apache/hadoop/hbase/master/TestDistributedLogSplitting.java
 Tue Nov 15 17:13:33 2011
@@ -202,15 +202,22 @@ public class TestDistributedLogSplitting
     FileSystem fs = master.getMasterFileSystem().getFileSystem();
 
     List<RegionServerThread> rsts = cluster.getLiveRegionServerThreads();
-    HRegionServer hrs = rsts.get(0).getRegionServer();
+    
     Path rootdir = FSUtils.getRootDir(conf);
-    final Path logDir = new Path(rootdir,
-        HLog.getHLogDirectoryName(hrs.getServerName().toString()));
 
     installTable(new ZooKeeperWatcher(conf, "table-creation", null),
         "table", "family", 40);
     byte[] table = Bytes.toBytes("table");
-    List<HRegionInfo> regions = hrs.getOnlineRegions();
+    List<HRegionInfo> regions = null;
+    HRegionServer hrs = null;
+    for (int i = 0; i < NUM_RS; i++) {
+      hrs = rsts.get(i).getRegionServer();
+      regions = hrs.getOnlineRegions();
+      if (regions.size() != 0) break;
+    }
+    final Path logDir = new Path(rootdir, HLog.getHLogDirectoryName(hrs
+        .getServerName().toString()));
+    
     LOG.info("#regions = " + regions.size());
     Iterator<HRegionInfo> it = regions.iterator();
     while (it.hasNext()) {