diff --git a/src/java/azkaban/execapp/JobRunner.java b/src/java/azkaban/execapp/JobRunner.java
index e6d1e4e..03ac403 100644
--- a/src/java/azkaban/execapp/JobRunner.java
+++ b/src/java/azkaban/execapp/JobRunner.java
@@ -389,8 +389,8 @@ public class JobRunner extends EventHandler implements Runnable {
try {
File file = new File(attachmentFileName);
if (!file.exists()) {
- flowLogger.info("Attachment file for job " + this.jobId +
- " does not exist.");
+ flowLogger.info("No attachment file for job " + this.jobId +
+ " written.");
return;
}
loader.uploadAttachmentFile(
@@ -415,6 +415,7 @@ public class JobRunner extends EventHandler implements Runnable {
return;
}
+ createAttachmentFile();
createLogger();
boolean errorFound = false;
// Delay execution if necessary. Will return a true if something went wrong.
diff --git a/src/java/azkaban/jobtype/JobTypeManager.java b/src/java/azkaban/jobtype/JobTypeManager.java
index a5c2064..6c275af 100644
--- a/src/java/azkaban/jobtype/JobTypeManager.java
+++ b/src/java/azkaban/jobtype/JobTypeManager.java
@@ -365,13 +365,13 @@ public class JobTypeManager
if (jobtypeJobProps.containsKey(jobType)) {
Props p = jobtypeJobProps.get(jobType);
for (String k : p.getKeySet()) {
- if(!jobConf.containsKey(k)) {
+ if (!jobConf.containsKey(k)) {
jobConf.put(k, p.get(k));
}
}
}
jobConf = PropsUtils.resolveProps(jobConf);
-
+
if (sysConf != null) {
sysConf = PropsUtils.resolveProps(sysConf);
}
@@ -382,7 +382,8 @@ public class JobTypeManager
// logger.info("sysConf is " + sysConf);
// logger.info("jobConf is " + jobConf);
//
- job = (Job)Utils.callConstructor(executorClass, jobId, sysConf, jobConf, logger);
+ job = (Job) Utils.callConstructor(
+ executorClass, jobId, sysConf, jobConf, logger);
}
catch (Exception e) {
//job = new InitErrorJob(jobId, e);
