diff --git hcatalog/webhcat/svr/src/main/config/webhcat-log4j.properties hcatalog/webhcat/svr/src/main/config/webhcat-log4j.properties index 47d6e5f..866052c 100644 --- hcatalog/webhcat/svr/src/main/config/webhcat-log4j.properties +++ hcatalog/webhcat/svr/src/main/config/webhcat-log4j.properties @@ -16,7 +16,7 @@ # under the License. # Define some default values that can be overridden by system properties -webhcat.root.logger = DEBUG, standard +webhcat.root.logger = INFO, standard webhcat.log.dir = . webhcat.log.file = webhcat.log diff --git hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/AppConfig.java hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/AppConfig.java index 5f5ee54..3ffe686 100644 --- hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/AppConfig.java +++ hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/AppConfig.java @@ -158,7 +158,7 @@ private boolean loadOneFileConfig(String dir, String fname) { File f = new File(dir, fname); if (f.exists()) { addResource(new Path(f.getAbsolutePath())); - LOG.debug("loaded config file " + f.getAbsolutePath()); + LOG.info("loaded config file " + f.getAbsolutePath()); return true; } } diff --git hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/CompleteDelegator.java hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/CompleteDelegator.java index 4cee5bc..010e8af 100644 --- hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/CompleteDelegator.java +++ hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/CompleteDelegator.java @@ -60,12 +60,12 @@ public CompleteBean run(String id) try { state = new JobState(id, Main.getAppConfigInstance()); if (state.getCompleteStatus() == null) - failed("Job not yet complete", null); + failed("Job not yet complete. jobId=" + id, null); Long notified = state.getNotifiedTime(); if (notified != null) - return acceptWithError("Callback already run on " - + new Date(notified.longValue())); + return acceptWithError("Callback already run for jobId=" + id + + " at " + new Date(notified)); String callback = state.getCallback(); if (callback == null) diff --git hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Server.java hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Server.java index 3fcae2b..306421a 100644 --- hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Server.java +++ hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Server.java @@ -727,7 +727,7 @@ public QueueStatusBean deleteQueueId(@PathParam("jobid") String jobid) } /** - * Notify on a completed job. + * Notify on a completed job. Called by JobTracker. */ @GET @Path("internal/complete/{jobid}") diff --git hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/tool/HDFSStorage.java hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/tool/HDFSStorage.java index 14956da..dcaceb1 100644 --- hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/tool/HDFSStorage.java +++ hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/tool/HDFSStorage.java @@ -102,7 +102,9 @@ public String getField(Type type, String id, String key) { } return val; } catch (Exception e) { - LOG.info("Couldn't find " + p + ": " + e.getMessage(), e); + //don't print stack trace since clients poll for 'exitValue', 'completed', + //files which are not there until job completes + LOG.info("Couldn't find " + p + ": " + e.getMessage()); } finally { close(in); }