Improve handling of container launch errors (#73)

izeigerman · Feb 14, 2019 · 4039db3 · 4039db3
1 parent 0527a93
commit 4039db3
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/akkeeper/src/main/scala/akkeeper/deploy/yarn/YarnApplicationMaster.scala b/akkeeper/src/main/scala/akkeeper/deploy/yarn/YarnApplicationMaster.scala
@@ -214,12 +214,14 @@ private[akkeeper] class YarnApplicationMaster(config: YarnApplicationMasterConfi
             try {
               launchInstance(container, containerDef, instanceId)
             } catch {
-              case NonFatal(e) => logger.error(s"Failed to launch instance $instanceId", e)
+              case NonFatal(e) =>
+                logger.error(s"Failed to launch instance $instanceId", e)
+                onStartContainerError(container.getId, e)
             }
           }
         })
       } else {
-        logger.debug(s"Unknown container allocation ${container.getId}. Realesing container")
+        logger.debug(s"Unknown container allocation ${container.getId}. Releasing container")
         yarnClient.releaseAssignedContainer(container.getId)
       }
     }