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

HBASE-21354 Addendum fix compile error

This commit is contained in:
Duo Zhang 2018-10-23 14:39:53 +08:00
parent 86f23128b0
commit 603bf4c551
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/ProcedureTestingUtility.java
View File

@ -96,9 +96,15 @@ public class ProcedureTestingUtility {
public static <TEnv> void restart(ProcedureExecutor<TEnv> procExecutor, public static <TEnv> void restart(ProcedureExecutor<TEnv> procExecutor,
boolean avoidTestKillDuringRestart, boolean failOnCorrupted, Callable<Void> stopAction, boolean avoidTestKillDuringRestart, boolean failOnCorrupted, Callable<Void> stopAction,
Callable<Void> actionBeforeStartWorker, Callable<Void> startAction, Callable<Void> actionBeforeStartWorker, Callable<Void> startAction) throws Exception {
boolean abort, boolean startWorkers) restart(procExecutor, avoidTestKillDuringRestart, failOnCorrupted, stopAction,
throws Exception { actionBeforeStartWorker, startAction, false, true);
}
public static <TEnv> void restart(ProcedureExecutor<TEnv> procExecutor,
boolean avoidTestKillDuringRestart, boolean failOnCorrupted, Callable<Void> stopAction,
Callable<Void> actionBeforeStartWorker, Callable<Void> startAction, boolean abort,
boolean startWorkers) throws Exception {
final ProcedureStore procStore = procExecutor.getStore(); final ProcedureStore procStore = procExecutor.getStore();
final int storeThreads = procExecutor.getCorePoolSize(); final int storeThreads = procExecutor.getCorePoolSize();
final int execThreads = procExecutor.getCorePoolSize(); final int execThreads = procExecutor.getCorePoolSize();