diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSmallTests.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSmallTests.java index 8efa67ef0ff..e3cc6e93e90 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSmallTests.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSmallTests.java @@ -732,7 +732,9 @@ public class TestReplicationSmallTests extends TestReplicationBase { ClusterStatus status = admin.getClusterStatus(); - for (ServerName server : status.getServers()) { + for (JVMClusterUtil.RegionServerThread thread : + utility1.getHBaseCluster().getRegionServerThreads()) { + ServerName server = thread.getRegionServer().getServerName(); ServerLoad sl = status.getLoad(server); List rLoadSourceList = sl.getReplicationLoadSourceList(); ReplicationLoadSink rLoadSink = sl.getReplicationLoadSink();