From 12fd6d2a2495533726d84759fd6cc754b5f7eb97 Mon Sep 17 00:00:00 2001 From: Jimmy Xiang Date: Fri, 3 Oct 2014 14:06:49 -0700 Subject: [PATCH] HBASE-12166 TestDistributedLogSplitting.testMasterStartsUpWithLogReplayWork --- .../coordination/ZKSplitLogManagerCoordination.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/coordination/ZKSplitLogManagerCoordination.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/coordination/ZKSplitLogManagerCoordination.java index 07986f257fb..2983276edd3 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/coordination/ZKSplitLogManagerCoordination.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/coordination/ZKSplitLogManagerCoordination.java @@ -341,8 +341,8 @@ public class ZKSplitLogManagerCoordination extends ZooKeeperListener implements if (recoveredServerNameSet.containsAll(failedServers)) { ZKUtil.deleteNodeRecursively(watcher, nodePath); } else { - listSize = failedServers.size(); - for (int j = 0; j < listSize; j++) { + int tmpFailedServerSize = failedServers.size(); + for (int j = 0; j < tmpFailedServerSize; j++) { String failedServer = failedServers.get(j); if (recoveredServerNameSet.contains(failedServer)) { String tmpPath = ZKUtil.joinZNode(nodePath, failedServer); @@ -733,9 +733,9 @@ public class ZKSplitLogManagerCoordination extends ZooKeeperListener implements continue; } boolean needMoreRecovery = false; - listSize = regionFailedServers.size(); - for (i = 0; i < listSize; i++) { - if (knownFailedServers.contains(regionFailedServers.get(i))) { + int tmpFailedServerSize = regionFailedServers.size(); + for (int j = 0; j < tmpFailedServerSize; j++) { + if (knownFailedServers.contains(regionFailedServers.get(j))) { needMoreRecovery = true; break; }