You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2018/10/23 06:43:57 UTC
hbase git commit: HBASE-21354 Addendum fix compile error
Repository: hbase
Updated Branches:
refs/heads/master 86f23128b -> 603bf4c55
HBASE-21354 Addendum fix compile error
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/603bf4c5
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/603bf4c5
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/603bf4c5
Branch: refs/heads/master
Commit: 603bf4c55106de17e559f37d24df2b5dea6e64e4
Parents: 86f2312
Author: Duo Zhang <zh...@apache.org>
Authored: Tue Oct 23 14:39:53 2018 +0800
Committer: Duo Zhang <zh...@apache.org>
Committed: Tue Oct 23 14:39:53 2018 +0800
----------------------------------------------------------------------
.../hbase/procedure2/ProcedureTestingUtility.java | 12 +++++++++---
1 file changed, 9 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/603bf4c5/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/ProcedureTestingUtility.java
----------------------------------------------------------------------
diff --git a/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/ProcedureTestingUtility.java b/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/ProcedureTestingUtility.java
index 843b724..95e0320 100644
--- a/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/ProcedureTestingUtility.java
+++ b/hbase-procedure/src/test/java/org/apache/hadoop/hbase/procedure2/ProcedureTestingUtility.java
@@ -96,9 +96,15 @@ public class ProcedureTestingUtility {
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 {
+ Callable<Void> actionBeforeStartWorker, Callable<Void> startAction) throws Exception {
+ restart(procExecutor, avoidTestKillDuringRestart, failOnCorrupted, stopAction,
+ 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 int storeThreads = procExecutor.getCorePoolSize();
final int execThreads = procExecutor.getCorePoolSize();