You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by jx...@apache.org on 2014/06/13 17:55:51 UTC
git commit: HBASE-10871 Indefinite OPEN/CLOSE wait on busy
RegionServers (Esteban)
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 <jx...@cloudera.com>
Authored: Fri Jun 13 08:52:09 2014 -0700
Committer: Jimmy Xiang <jx...@cloudera.com>
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;" +