In JobCompletionService log job ID with error message

Netflix · Nov 20, 2017 · b0a0dc8 · b0a0dc8
1 parent 15b79df
commit b0a0dc8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/genie-web/src/main/java/com/netflix/genie/web/tasks/job/JobCompletionService.java b/genie-web/src/main/java/com/netflix/genie/web/tasks/job/JobCompletionService.java
@@ -278,7 +278,7 @@ private void cleanupProcesses(final String jobId) {
                 });
             }
         } catch (final GenieException ge) {
-            log.error("Unable to cleanup process for job due to exception. {}", jobId, ge);
+            log.error("Unable to cleanup process for job {} due to exception.", jobId, ge);
             incrementErrorCounter("JOB_CLEANUP_FAILURE", ge);
         } catch (Throwable t) {
             incrementErrorCounter("JOB_PROCESS_CLEANUP_FAILURE", t);
@@ -546,7 +546,7 @@ private boolean processJobDir(final Job job) throws GenieException, IOException
                     try {
                         this.executor.execute(commandLine);
                     } catch (Throwable t) {
-                        log.warn("Failed to created archive of job files", t);
+                        log.warn("Failed to created archive of job files for job: {}", jobId, t);
                         incrementErrorCounter("JOB_ARCHIVAL_FAILURE", t);
                         throw t;
                     }