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 671fd7c..82a10d5 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 @@ -836,8 +836,7 @@ public class AssignmentManager extends ZooKeeperListener { break; } // Run handler to do the rest of the SPLIT handling. - this.executorService.submit(new SplitRegionHandler(server, this, - regionState.getRegion(), sn, daughters)); + new SplitRegionHandler(server, this, regionState.getRegion(), sn, daughters).process(); break; case RS_ZK_REGION_MERGING: @@ -872,8 +871,7 @@ public class AssignmentManager extends ZooKeeperListener { + merge_a + ", rs_b=" + merge_b); } // Run handler to do the rest of the MERGED handling. - this.executorService.submit(new MergedRegionHandler( - server, this, sn, mergeRegions)); + new MergedRegionHandler(server, this, sn, mergeRegions).process(); break; case M_ZK_REGION_CLOSING: @@ -907,8 +905,7 @@ public class AssignmentManager extends ZooKeeperListener { regionState = regionStates.updateRegionState(rt, RegionState.State.CLOSED); if (regionState != null) { removeClosedRegion(regionState.getRegion()); - this.executorService.submit(new ClosedRegionHandler(server, - this, regionState.getRegion())); + new ClosedRegionHandler(server, this, regionState.getRegion()).process(); } break; @@ -941,8 +938,7 @@ public class AssignmentManager extends ZooKeeperListener { // When there are more than one region server a new RS is selected as the // destination and the same is updated in the regionplan. (HBASE-5546) getRegionPlan(regionState.getRegion(), sn, true); - this.executorService.submit(new ClosedRegionHandler(server, - this, regionState.getRegion())); + new ClosedRegionHandler(server, this, regionState.getRegion()).process(); } } break; @@ -980,8 +976,8 @@ public class AssignmentManager extends ZooKeeperListener { regionState = regionStates.updateRegionState(rt, RegionState.State.OPEN); if (regionState != null) { failedOpenTracker.remove(encodedName); // reset the count, if any - this.executorService.submit(new OpenedRegionHandler( - server, this, regionState.getRegion(), sn, expectedVersion)); + new OpenedRegionHandler( + server, this, regionState.getRegion(), sn, expectedVersion).process(); } break;