Skip to content

Commit

Permalink
add emitIntermediateResults, change default logging to info, decrease…
Browse files Browse the repository at this point in the history
… duplicate logging in StatusUpdater (#149)
  • Loading branch information
tballison committed Jun 16, 2023
1 parent 490451d commit 0c932f8
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -231,6 +231,7 @@ private void appendAsync(BatchProcessConfig bpc, DomWriter writer, Element prope
AppContext.getInstance().getJavaHome().resolve("java").toString());
writer.appendTextElement(params, "numClients", Integer.toString(bpc.getNumProcesses()));
writer.appendTextElement(params, "numEmitters", "1");
writer.appendTextElement(params, "emitIntermediateResults", "true");
writer.appendListElement(params, "forkedJvmArgs", "arg", "-Xmx" + bpc.getMaxMemMb() + "m",
"-Dlog4j.configurationFile=" + AppContext.ASYNC_LOG4J2_PATH.toAbsolutePath(), "-cp",
buildClassPath(bpc));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ public Integer call() throws Exception {

while (true) {
Optional<AsyncStatus> asyncStatusOptional = batchProcess.checkAsyncStatus();
LOGGER.debug(asyncStatusOptional);

if (asyncStatusOptional.isPresent()) {
AsyncStatus asyncStatus = asyncStatusOptional.get();
long processed = 0;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,8 +24,8 @@
</Console>
</Appenders>
<Loggers>
<Root level="trace">
<Root level="info">
<AppenderRef ref="Console"/>
</Root>
</Loggers>
</Configuration>
</Configuration>

0 comments on commit 0c932f8

Please sign in to comment.