[jb] Fix issue in getting the logs if the job had failed
@@ -65,6 +65,7 @@ class JobApi(Api):
return self._get_api(appid).profile(appid, app_type, app_property, app_filters)
def _get_api(self, appid):
+ try:
if type(appid) == list:
return self.yarn_api
elif appid.startswith('task_'):
@@ -77,6 +78,8 @@ class JobApi(Api):
return SparkExecutorApi(self.user, appid)
else:
return self.yarn_api # application_
+ except:
+ raise PopupException("Job would have failed due to which there no attempt or appattempt information available")
def _set_request(self, request):
self.request = request
