Skip to content
Permalink
Browse files
Remove external comps. and replace foreach
  • Loading branch information
DomGarguilo committed Aug 23, 2021
1 parent 52b1770 commit a51ef0757a6b8dced0c421838996211a283a0b18
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 7 deletions.
@@ -42,7 +42,10 @@ test.ci.common.auths=
# Accumulo tserver properties to set when creating a table
test.ci.common.accumulo.server.props=\
tserver.compaction.major.service.cs1.planner=org.apache.accumulo.core.spi.compaction.DefaultCompactionPlanner \
tserver.compaction.major.service.cs1.planner.opts.executors=[{"name":"small","type":"internal","maxSize":"32M","numThreads":4},{"name":"medium","type":"internal","maxSize":"128M","numThreads":2},{"name":"large","type":"external","queue":"DCQ1"}]
tserver.compaction.major.service.cs1.planner.opts.executors=\
[{"name":"small","type":"internal","maxSize":"16M","numThreads":8},\
{"name":"medium","type":"internal","maxSize":"128M","numThreads":4},\
{"name":"large","type":"internal","numThreads":2}]

# Accumulo table properties to set when creating table
test.ci.common.accumulo.table.props=\
@@ -59,13 +59,14 @@ public static void main(String[] args) throws Exception {

// retrieve and set tserver props
Map<String,String> props = getProps(env, TestProps.CI_COMMON_ACCUMULO_SERVER_PROPS);
props.forEach((k, v) -> {
try {
client.instanceOperations().setProperty(k, v);
} catch (AccumuloException | AccumuloSecurityException e) {
e.printStackTrace();
try {
for (Map.Entry<String,String> entry : props.entrySet()) {
client.instanceOperations().setProperty(entry.getKey(), entry.getValue());
}
});
} catch (AccumuloException | AccumuloSecurityException e) {
log.error("Failed to set tserver props");
throw new Exception(e);
}

SortedSet<Text> splits = new TreeSet<>();
final int numSplits = numTablets - 1;

0 comments on commit a51ef07

Please sign in to comment.