|
@@ -242,7 +242,7 @@ class YarnApi(JobBrowserApi):
|
|
|
if app['finalStatus'] in ('SUCCEEDED', 'FAILED', 'KILLED'):
|
|
if app['finalStatus'] in ('SUCCEEDED', 'FAILED', 'KILLED'):
|
|
|
if app['applicationType'] == 'SPARK':
|
|
if app['applicationType'] == 'SPARK':
|
|
|
job = SparkJob(app, rm_api=self.resource_manager_api, hs_api=self.spark_history_server_api)
|
|
job = SparkJob(app, rm_api=self.resource_manager_api, hs_api=self.spark_history_server_api)
|
|
|
- elif app['state'] == 'KILLED':
|
|
|
|
|
|
|
+ elif app['state'] in ('KILLED', 'FAILED'):
|
|
|
job = KilledYarnJob(self.resource_manager_api, app)
|
|
job = KilledYarnJob(self.resource_manager_api, app)
|
|
|
else: # Job succeeded, attempt to fetch from JHS
|
|
else: # Job succeeded, attempt to fetch from JHS
|
|
|
job = self._get_job_from_history_server(job_id)
|
|
job = self._get_job_from_history_server(job_id)
|