26
26
import org .apache .hadoop .hbase .Cell ;
27
27
import org .apache .hadoop .hbase .HBaseClassTestRule ;
28
28
import org .apache .hadoop .hbase .HBaseTestingUtility ;
29
+ import org .apache .hadoop .hbase .HConstants ;
29
30
import org .apache .hadoop .hbase .TableName ;
30
31
import org .apache .hadoop .hbase .Waiter .ExplainingPredicate ;
31
32
import org .apache .hadoop .hbase .client .ColumnFamilyDescriptorBuilder ;
@@ -107,6 +108,7 @@ public static void setUp() throws Exception {
107
108
UTIL .getConfiguration ().setLong (ProcedureExecutor .WORKER_KEEP_ALIVE_TIME_CONF_KEY , 5000 );
108
109
UTIL .getConfiguration ().setInt (MasterProcedureConstants .MASTER_PROCEDURE_THREADS , 4 );
109
110
UTIL .getConfiguration ().set (CoprocessorHost .REGION_COPROCESSOR_CONF_KEY , MyCP .class .getName ());
111
+ UTIL .getConfiguration ().setInt (HConstants .REGION_SERVER_HANDLER_COUNT , 100 );
110
112
UTIL .startMiniCluster (3 );
111
113
CORE_POOL_SIZE =
112
114
UTIL .getMiniHBaseCluster ().getMaster ().getMasterProcedureExecutor ().getCorePoolSize ();
@@ -118,7 +120,7 @@ public static void setUp() throws Exception {
118
120
.setColumnFamily (ColumnFamilyDescriptorBuilder .of (CF )).build ()));
119
121
}
120
122
for (Future <?> future : futures ) {
121
- future .get (1 , TimeUnit .MINUTES );
123
+ future .get (3 , TimeUnit .MINUTES );
122
124
}
123
125
UTIL .getAdmin ().balance (true );
124
126
UTIL .waitUntilNoRegionsInTransition ();
0 commit comments