diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java index bf86e628e45..0ec7b147cb5 100644 --- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java +++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java @@ -961,7 +961,7 @@ private void unlockJob() { try { this.jobLockOptional.get().close(); } catch (IOException e) { - LOG.error(String.format("Failed to close job lock for job %s: %s", this.jobContext.getJobId(), e), e); + LOG.error(String.format("Failed to close job lock for job %s: %s", this.jobProps.getProperty(ConfigurationKeys.JOB_NAME_KEY), e), e); } finally { this.jobLockOptional = Optional.absent(); }