SAMZA-1250: JobRunner.kill doesn't terminate cleanly with YarnJob.
authorJacob Maes <jmaes@linkedin.com>
Mon, 1 May 2017 20:44:54 +0000 (13:44 -0700)
committerJacob Maes <jmaes@linkedin.com>
Mon, 1 May 2017 20:44:54 +0000 (13:44 -0700)
commita1e03af0da684184fbd95ec4278fc35fe4b4e28b
tree64419a0198b6759ddfa28c351b1f5aa45840698d
parent92ae4c628abb3d113520ec47ca82f08c480123ad
SAMZA-1250: JobRunner.kill doesn't terminate cleanly with YarnJob.

1. The ClientHelper now checks inactive application IDs so it can get status for terminated jobs in addition to running jobs
2. JobRunner.kill() waits for any finish, not just successful finish.
3. A killed job is now considered successful.

Author: Jacob Maes <jmaes@linkedin.com>

Reviewers: Prateek Maheshwari <pmaheshw@linkedin.com>

Closes #152 from jmakes/samza-1250
samza-core/src/main/scala/org/apache/samza/job/JobRunner.scala
samza-yarn/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala
samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala