Skip to content
Permalink
Browse files
fix build errors
  • Loading branch information
Manno15 committed Feb 11, 2021
1 parent 689d6d4 commit 88ffaac2e75f2eac5e4f0dcb2ab61e7183276543
Showing 4 changed files with 15 additions and 15 deletions.
@@ -43,7 +43,7 @@
import javax.xml.validation.SchemaFactory;

import org.apache.accumulo.core.client.security.tokens.PasswordToken;
import org.apache.accumulo.core.util.SimpleThreadPool;
import org.apache.accumulo.core.util.threads.ThreadPools;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.w3c.dom.Document;
@@ -224,7 +224,7 @@ public void visit(final State state, final RandWalkEnv env, Properties props) th
fixture.setUp(state, env);
}

ExecutorService service = new SimpleThreadPool(1, "RandomWalk Runner");
ExecutorService service = ThreadPools.createFixedThreadPool(1, "RandomWalk Runner", false);

try {
Node initNode = getNode(initNodeId);
@@ -26,7 +26,7 @@
import org.apache.accumulo.core.client.admin.TableOperations;
import org.apache.accumulo.core.iterators.LongCombiner;
import org.apache.accumulo.core.iterators.user.SummingCombiner;
import org.apache.accumulo.core.util.SimpleThreadPool;
import org.apache.accumulo.core.util.threads.ThreadPools;
import org.apache.accumulo.testing.randomwalk.RandWalkEnv;
import org.apache.accumulo.testing.randomwalk.State;
import org.apache.accumulo.testing.randomwalk.Test;
@@ -60,8 +60,8 @@ public void visit(State state, RandWalkEnv env, Properties props) throws Excepti
state.set("fs", FileSystem.get(env.getHadoopConfiguration()));
state.set("bulkImportSuccess", "true");
BulkPlusOne.counter.set(0l);

ThreadPoolExecutor e = new SimpleThreadPool(MAX_POOL_SIZE, "bulkImportPool");
ThreadPoolExecutor e = ThreadPools.createFixedThreadPool(MAX_POOL_SIZE, "bulkImportPool",
false);
state.set("pool", e);
}

@@ -84,14 +84,14 @@ static Setting s(Property property, long min, long max) {
s(Property.TSERV_WAL_BLOCKSIZE, 1024 * 1024,
1024 * 1024 * 1024 * 10L),
s(Property.TSERV_WORKQ_THREADS, 1, 10),
s(Property.MASTER_BULK_THREADPOOL_SIZE, 1, 10),
s(Property.MASTER_BULK_RETRIES, 1, 10),
s(Property.MASTER_BULK_TIMEOUT, 10, 600),
s(Property.MASTER_FATE_THREADPOOL_SIZE, 1, 100),
s(Property.MASTER_RECOVERY_DELAY, 0, 100),
s(Property.MASTER_LEASE_RECOVERY_WAITING_PERIOD, 0, 10),
s(Property.MASTER_THREADCHECK, 100, 10000),
s(Property.MASTER_MINTHREADS, 1, 200),};
s(Property.MANAGER_BULK_THREADPOOL_SIZE, 1, 10),
s(Property.MANAGER_BULK_RETRIES, 1, 10),
s(Property.MANAGER_BULK_TIMEOUT, 10, 600),
s(Property.MANAGER_FATE_THREADPOOL_SIZE, 1, 100),
s(Property.MANAGER_RECOVERY_DELAY, 0, 100),
s(Property.MANAGER_LEASE_RECOVERY_WAITING_PERIOD, 0, 10),
s(Property.MANAGER_THREADCHECK, 100, 10000),
s(Property.MANAGER_MINTHREADS, 1, 200),};

Setting[] tableSettings = {
s(Property.TABLE_MAJC_RATIO, 1, 10),
@@ -17,7 +17,7 @@
package org.apache.accumulo.testing.randomwalk.concurrent;

import static com.google.common.util.concurrent.Uninterruptibles.sleepUninterruptibly;
import static org.apache.accumulo.core.conf.Property.MASTER_REPLICATION_SCAN_INTERVAL;
import static org.apache.accumulo.core.conf.Property.MANAGER_REPLICATION_SCAN_INTERVAL;
import static org.apache.accumulo.core.conf.Property.REPLICATION_NAME;
import static org.apache.accumulo.core.conf.Property.REPLICATION_PEERS;
import static org.apache.accumulo.core.conf.Property.REPLICATION_PEER_PASSWORD;
@@ -74,7 +74,7 @@ public void visit(State state, RandWalkEnv env, Properties props) throws Excepti
iOps.setProperty(REPLICATION_PEER_USER.getKey() + instName, env.getAccumuloUserName());
iOps.setProperty(REPLICATION_PEER_PASSWORD.getKey() + instName, env.getAccumuloPassword());
// Tweak some replication parameters to make the replication go faster
iOps.setProperty(MASTER_REPLICATION_SCAN_INTERVAL.getKey(), "1s");
iOps.setProperty(MANAGER_REPLICATION_SCAN_INTERVAL.getKey(), "1s");
iOps.setProperty(REPLICATION_WORK_ASSIGNMENT_SLEEP.getKey(), "1s");
iOps.setProperty(REPLICATION_WORK_PROCESSOR_DELAY.getKey(), "1s");
iOps.setProperty(REPLICATION_WORK_PROCESSOR_PERIOD.getKey(), "1s");

0 comments on commit 88ffaac

Please sign in to comment.