diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServerReefEventHandler.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServerReefEventHandler.java index 01bfb8c91d..5e8de3339e 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServerReefEventHandler.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServerReefEventHandler.java @@ -29,6 +29,7 @@ import org.apache.reef.util.logging.LoggingScopeFactory; import org.apache.reef.util.logging.LoggingScopeImpl; import org.apache.reef.wake.EventHandler; + import javax.inject.Inject; import javax.servlet.ServletException; import javax.servlet.http.HttpServletResponse; @@ -169,17 +170,17 @@ public void onHttpRequest( final List names = parsedHttpRequest.getQueryMap().get("filename"); if (names == null || names.size() == 0) { response.getWriter().println(String.format("File name is not provided")); - } - - final String fileName = (String)names.get(0); - if (!fileName.equals(driverStdoutFile) && !fileName.equals(driverStderrFile)) { - response.getWriter().println(String.format("Unsupported file names: [%s] ", fileName)); - } - try { - final byte[] outputBody = readFile((String) names.get(0)).getBytes(StandardCharsets.UTF_8); - response.getOutputStream().write(outputBody); - } catch(final IOException e) { - response.getWriter().println(String.format("Cannot find the log file: [%s].", fileName)); + } else { + final String fileName = (String) names.get(0); + if (!fileName.equals(driverStdoutFile) && !fileName.equals(driverStderrFile)) { + response.getWriter().println(String.format("Unsupported file names: [%s] ", fileName)); + } + try { + final byte[] outputBody = readFile((String) names.get(0)).getBytes(StandardCharsets.UTF_8); + response.getOutputStream().write(outputBody); + } catch (final IOException e) { + response.getWriter().println(String.format("Cannot find the log file: [%s].", fileName)); + } } break; default: @@ -275,7 +276,7 @@ private void writeEvaluatorInfoWebOutput( * Get all evaluator ids and send it back to response as JSON. */ private void writeEvaluatorsJsonOutput(final HttpServletResponse response) throws IOException { - LOG.log(Level.INFO, "HttpServerReefEventHandler getEvaluators is called"); + LOG.log(Level.INFO, "HttpServerReefEventHandler writeEvaluatorsJsonOutput is called"); try { final EvaluatorListSerializer serializer = Tang.Factory.getTang().newInjector().getInstance(EvaluatorListSerializer.class); @@ -297,7 +298,7 @@ private void writeEvaluatorsJsonOutput(final HttpServletResponse response) throw */ private void writeEvaluatorsWebOutput(final HttpServletResponse response) throws IOException { - LOG.log(Level.INFO, "HttpServerReefEventHandler getEvaluators is called"); + LOG.log(Level.INFO, "HttpServerReefEventHandler writeEvaluatorsWebOutput is called"); final PrintWriter writer = response.getWriter(); @@ -324,6 +325,9 @@ private void writeEvaluatorsWebOutput(final HttpServletResponse response) throws * Write Driver Info as JSON string to Response. */ private void writeDriverJsonInformation(final HttpServletResponse response) throws IOException { + + LOG.log(Level.INFO, "HttpServerReefEventHandler writeDriverJsonInformation invoked."); + try { final DriverInfoSerializer serializer = Tang.Factory.getTang().newInjector().getInstance(DriverInfoSerializer.class); @@ -350,7 +354,7 @@ private void writeResponse(final HttpServletResponse response, final String data */ private void writeDriverWebInformation(final HttpServletResponse response) throws IOException { - LOG.log(Level.INFO, "HttpServerReefEventHandler writeDriverInformation invoked."); + LOG.log(Level.INFO, "HttpServerReefEventHandler writeDriverWebInformation invoked."); final PrintWriter writer = response.getWriter();