diff --git a/azkaban-execserver/src/main/java/azkaban/execapp/JobRunner.java b/azkaban-execserver/src/main/java/azkaban/execapp/JobRunner.java
index 51af93d..c2ed6d5 100644
--- a/azkaban-execserver/src/main/java/azkaban/execapp/JobRunner.java
+++ b/azkaban-execserver/src/main/java/azkaban/execapp/JobRunner.java
@@ -359,7 +359,7 @@ public class JobRunner extends EventHandler implements Runnable {
return false;
}
- private void finalizeLogFile(int attempNo) {
+ private void finalizeLogFile(int attemptNo) {
closeLogger();
if (logFile == null) {
flowLogger.info("Log file for job " + this.jobId + " is null");
@@ -375,7 +375,7 @@ public class JobRunner extends EventHandler implements Runnable {
});
Arrays.sort(files, Collections.reverseOrder());
- loader.uploadLogFile(executionId, this.node.getNestedId(), attempNo,
+ loader.uploadLogFile(executionId, this.node.getNestedId(), attemptNo,
files);
} catch (ExecutorManagerException e) {
flowLogger.error(
@@ -456,12 +456,13 @@ public class JobRunner extends EventHandler implements Runnable {
// it being a legitimate failure.
changeStatus(Status.KILLED);
}
- logInfo("Finishing job " + this.jobId + " attempt: " + node.getAttempt()
- + " at " + node.getEndTime() + " with status " + node.getStatus());
- int attempNo = node.getAttempt();
+ int attemptNo = node.getAttempt();
+ logInfo("Finishing job " + this.jobId + " attempt: " + attemptNo + " at "
+ + node.getEndTime() + " with status " + node.getStatus());
+
fireEvent(Event.create(this, Type.JOB_FINISHED), false);
- finalizeLogFile(attempNo);
+ finalizeLogFile(attemptNo);
finalizeAttachmentFile();
writeStatus();
}