Skip to content
Permalink
Browse files
Use correct createFixedThreadPool function
  • Loading branch information
Manno15 committed Nov 23, 2021
1 parent 711d28e commit 33448f38e1c1c882d8a414d67610c3bcbb611c91
Showing 3 changed files with 4 additions and 4 deletions.
@@ -94,7 +94,8 @@ public class TestProps {
public static final String CI_INGEST_PAUSE_DURATION_MAX = CI_INGEST + "pause.duration.max";
// Amount of data to write before flushing. Pause checks are only done after flush.
public static final String CI_INGEST_FLUSH_ENTRIES = CI_INGEST + "entries.flush";
// The probability (between 0.0 and 1.0) that a set of entries will be deleted during continuous ingest
// The probability (between 0.0 and 1.0) that a set of entries will be deleted during continuous
// ingest
public static final String CI_INGEST_DELETE_PROBABILITY = CI_INGEST + "delete.probability";

/** Batch Walker **/
@@ -224,7 +224,7 @@ public void visit(final State state, final RandWalkEnv env, Properties props) th
fixture.setUp(state, env);
}

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

try {
Node initNode = getNode(initNodeId);
@@ -60,8 +60,7 @@ 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 = ThreadPools.createFixedThreadPool(MAX_POOL_SIZE, "bulkImportPool",
false);
ThreadPoolExecutor e = ThreadPools.createFixedThreadPool(MAX_POOL_SIZE, "bulkImportPool");
state.set("pool", e);
}

0 comments on commit 33448f3

Please sign in to comment.