Repository: hbase Updated Branches: refs/heads/master 55cecc967 -> 92b494df4
HBASE-10871 Indefinite OPEN/CLOSE wait on busy RegionServers (Esteban) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/92b494df Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/92b494df Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/92b494df Branch: refs/heads/master Commit: 92b494df459d0e3bbbda808c64889471cf915078 Parents: 55cecc96 Author: Jimmy Xiang <[email protected]> Authored: Fri Jun 13 08:52:09 2014 -0700 Committer: Jimmy Xiang <[email protected]> Committed: Fri Jun 13 08:52:09 2014 -0700 ---------------------------------------------------------------------- .../org/apache/hadoop/hbase/master/AssignmentManager.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/92b494df/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java index 529a333..597ddf9 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java @@ -1582,6 +1582,9 @@ public class AssignmentManager extends ZooKeeperListener { + " has timed out, but the regions might" + " already be opened on it.", e); } + // wait and reset the re-try count, server might be just busy. + Thread.sleep(100); + i--; continue; } throw e; @@ -1992,8 +1995,8 @@ public class AssignmentManager extends ZooKeeperListener { } } else if (retry) { needNewPlan = false; - LOG.warn(assignMsg + ", trying to assign to the same region server " + - "try=" + i + " of " + this.maximumAttempts, t); + i--; // we want to retry as many times as needed as long as the RS is not dead. + LOG.warn(assignMsg + ", trying to assign to the same region server due ", t); } else { needNewPlan = true; LOG.warn(assignMsg + ", trying to assign elsewhere instead;" +
