Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-16209 addendum fix region move delay

This commit is contained in:
zhangduo 2016-08-01 15:56:47 +08:00
parent 51c8c1891a
commit 1b303ad75d
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java
View File

@ -3412,7 +3412,7 @@ public class AssignmentManager extends ZooKeeperListener {
invokeAssign(regionInfo, true); invokeAssign(regionInfo, true);
} }
void invokeAssign(HRegionInfo regionInfo, boolean newPlan) { public void invokeAssign(HRegionInfo regionInfo, boolean newPlan) {
threadPoolExecutorService.submit(new AssignCallable(this, regionInfo, newPlan)); threadPoolExecutorService.submit(new AssignCallable(this, regionInfo, newPlan));
} }
@ -4498,8 +4498,10 @@ public class AssignmentManager extends ZooKeeperListener {
} }
private class DelayedAssignCallable implements Runnable { private class DelayedAssignCallable implements Runnable {
Callable callable;
public DelayedAssignCallable(Callable callable) { Callable<?> callable;
public DelayedAssignCallable(Callable<?> callable) {
this.callable = callable; this.callable = callable;
} }

2
hbase-server/src/main/java/org/apache/hadoop/hbase/master/handler/ClosedRegionHandler.java
View File

@ -103,6 +103,6 @@ public class ClosedRegionHandler extends EventHandler implements TotesHRegionInf
regionInfo, RegionState.State.CLOSED); regionInfo, RegionState.State.CLOSED);
// This below has to do w/ online enable/disable of a table // This below has to do w/ online enable/disable of a table
assignmentManager.removeClosedRegion(regionInfo); assignmentManager.removeClosedRegion(regionInfo);
assignmentManager.invokeAssignLaterOnFailure(regionInfo); assignmentManager.invokeAssign(regionInfo, false);
} }
} }