commit d2d0c128ec50312c0d3ed85a6e65e22280e8f4e6
author Yaniv Rodenski <yaniv@shinto.io> Mon Mar 25 16:15:16 2019 +1100
committer Yaniv Rodenski <yaniv@shinto.io> Mon Mar 25 16:15:16 2019 +1100
tree 2319e3083ce399fc50afffab88b5a4def8eacab6
parent 89ebd0d8422669c2113ed10b698d7c87a78ace6f

fixed new-job-id

leader-yarn/src/main/kotlin/org/apache/amaterasu/leader/yarn/ApplicationMaster.kt

diff --git a/leader-yarn/src/main/kotlin/org/apache/amaterasu/leader/yarn/ApplicationMaster.kt b/leader-yarn/src/main/kotlin/org/apache/amaterasu/leader/yarn/ApplicationMaster.kt
index 2c107cf..b14b16f 100644
--- a/leader-yarn/src/main/kotlin/org/apache/amaterasu/leader/yarn/ApplicationMaster.kt
+++ b/leader-yarn/src/main/kotlin/org/apache/amaterasu/leader/yarn/ApplicationMaster.kt
@@ -165,7 +165,7 @@
         if (zkPath != null) {
             log.info("resuming job" + opts.newJobId)
             jobManager = JobLoader.reloadJob(
-                    opts.jobId,
+                    opts.newJobId,
                     client,
                     config.Jobs().tasks().attempts(),
                     LinkedBlockingQueue<ActionData>())