HBASE-10871 Indefinite OPEN/CLOSE wait on busy RegionServers (Esteban)
This commit is contained in:
parent
55cecc9679
commit
92b494df45
|
@ -1582,6 +1582,9 @@ public class AssignmentManager extends ZooKeeperListener {
|
||||||
+ " has timed out, but the regions might"
|
+ " has timed out, but the regions might"
|
||||||
+ " already be opened on it.", e);
|
+ " already be opened on it.", e);
|
||||||
}
|
}
|
||||||
|
// wait and reset the re-try count, server might be just busy.
|
||||||
|
Thread.sleep(100);
|
||||||
|
i--;
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
throw e;
|
throw e;
|
||||||
|
@ -1992,8 +1995,8 @@ public class AssignmentManager extends ZooKeeperListener {
|
||||||
}
|
}
|
||||||
} else if (retry) {
|
} else if (retry) {
|
||||||
needNewPlan = false;
|
needNewPlan = false;
|
||||||
LOG.warn(assignMsg + ", trying to assign to the same region server " +
|
i--; // we want to retry as many times as needed as long as the RS is not dead.
|
||||||
"try=" + i + " of " + this.maximumAttempts, t);
|
LOG.warn(assignMsg + ", trying to assign to the same region server due ", t);
|
||||||
} else {
|
} else {
|
||||||
needNewPlan = true;
|
needNewPlan = true;
|
||||||
LOG.warn(assignMsg + ", trying to assign elsewhere instead;" +
|
LOG.warn(assignMsg + ", trying to assign elsewhere instead;" +
|
||||||
|
|
Loading…
Reference in New Issue