Repository: hbase Updated Branches: refs/heads/branch-2 4676d4bf4 -> 0f5b0fb75
HBASE-19527 Make ExecutorService threads daemon=true Set the ProcedureExcecutor worker threads as daemon. Ditto for the timeout thread. Remove hack from TestRegionsOnMasterOptions that was put in place because the test would not go down. Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/5e4ed33f Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/5e4ed33f Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/5e4ed33f Branch: refs/heads/branch-2 Commit: 5e4ed33fa2e310578ee89517ac76940a1549f70b Parents: 4676d4b Author: Michael Stack <[email protected]> Authored: Fri Dec 15 13:57:16 2017 -0800 Committer: Michael Stack <[email protected]> Committed: Wed Jan 17 13:41:38 2018 -0800 ---------------------------------------------------------------------- .../apache/hadoop/hbase/procedure2/ProcedureExecutor.java | 2 ++ .../org/apache/hadoop/hbase/executor/ExecutorService.java | 2 +- .../hbase/master/balancer/TestRegionsOnMasterOptions.java | 10 ---------- 3 files changed, 3 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/5e4ed33f/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java ---------------------------------------------------------------------- diff --git a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java index 069bf28..7a964a8 100644 --- a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java +++ b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.java @@ -1710,6 +1710,7 @@ public class ProcedureExecutor<TEnvironment> { public WorkerThread(final ThreadGroup group) { super(group, "ProcExecWrkr-" + workerId.incrementAndGet()); + setDaemon(true); } @Override @@ -1784,6 +1785,7 @@ public class ProcedureExecutor<TEnvironment> { public TimeoutExecutorThread(final ThreadGroup group) { super(group, "ProcExecTimeout"); + setDaemon(true); } @Override http://git-wip-us.apache.org/repos/asf/hbase/blob/5e4ed33f/hbase-server/src/main/java/org/apache/hadoop/hbase/executor/ExecutorService.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/executor/ExecutorService.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/executor/ExecutorService.java index d04956b..342d441 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/executor/ExecutorService.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/executor/ExecutorService.java @@ -178,7 +178,7 @@ public class ExecutorService { // name the threads for this threadpool ThreadFactoryBuilder tfb = new ThreadFactoryBuilder(); tfb.setNameFormat(this.name + "-%d"); - // TODO: Should these executors be daemon threads? + tfb.setDaemon(true); this.threadPoolExecutor.setThreadFactory(tfb.build()); } http://git-wip-us.apache.org/repos/asf/hbase/blob/5e4ed33f/hbase-server/src/test/java/org/apache/hadoop/hbase/master/balancer/TestRegionsOnMasterOptions.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/balancer/TestRegionsOnMasterOptions.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/balancer/TestRegionsOnMasterOptions.java index 8f06886..51649e6 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/balancer/TestRegionsOnMasterOptions.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/balancer/TestRegionsOnMasterOptions.java @@ -23,7 +23,6 @@ import org.apache.hadoop.hbase.client.Table; import org.apache.hadoop.hbase.master.HMaster; import org.apache.hadoop.hbase.master.LoadBalancer; import org.apache.hadoop.hbase.regionserver.HRegion; -import org.apache.hadoop.hbase.regionserver.Region; import org.apache.hadoop.hbase.testclassification.MediumTests; import org.apache.hadoop.hbase.util.JVMClusterUtil; import org.apache.hadoop.hbase.util.Threads; @@ -196,15 +195,6 @@ public class TestRegionsOnMasterOptions { // still only carry system regions post crash. assertEquals(masterCount, mNewActualCount); } - // Disable balancer and wait till RIT done else cluster won't go down. - TEST_UTIL.getAdmin().balancerSwitch(false, true); - while (true) { - if (!TEST_UTIL.getHBaseCluster().getMaster().getAssignmentManager(). - isMetaRegionInTransition()) { - break; - } - Threads.sleep(10); - } } finally { LOG.info("Running shutdown of cluster"); TEST_UTIL.shutdownMiniCluster();
