Skip to content
Permalink
Browse files
Fixup testing for changes in Accumulo regarding ThreadPools (#197)
  • Loading branch information
dlmarion committed Mar 17, 2022
1 parent 1da4041 commit da4a4343d738f4861d7109290d3618f0a09c93b8
Showing 2 changed files with 4 additions and 3 deletions.
@@ -222,7 +222,8 @@ 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.getServerThreadPools().createFixedThreadPool(1,
"RandomWalk Runner", false);

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

0 comments on commit da4a434

Please sign in to comment.