|
@@ -138,7 +138,7 @@ def get_next_ha_mrcluster():
|
|
|
else:
|
|
else:
|
|
|
LOG.info('JobTracker %s is not RUNNING, skipping it: %s' % (name, status))
|
|
LOG.info('JobTracker %s is not RUNNING, skipping it: %s' % (name, status))
|
|
|
except Exception, ex:
|
|
except Exception, ex:
|
|
|
- LOG.info('JobTracker %s is not available, skipping it: %s' % (name, ex))
|
|
|
|
|
|
|
+ LOG.exception('JobTracker %s is not available, skipping it: %s' % (name, ex))
|
|
|
else:
|
|
else:
|
|
|
return (config, jt)
|
|
return (config, jt)
|
|
|
return None
|
|
return None
|
|
@@ -198,7 +198,7 @@ def get_next_ha_yarncluster():
|
|
|
else:
|
|
else:
|
|
|
LOG.info('RM %s is not RUNNING, skipping it: %s' % (name, cluster_info))
|
|
LOG.info('RM %s is not RUNNING, skipping it: %s' % (name, cluster_info))
|
|
|
except Exception, ex:
|
|
except Exception, ex:
|
|
|
- LOG.info('RM %s is not available, skipping it: %s' % (name, ex))
|
|
|
|
|
|
|
+ LOG.exception('RM %s is not available, skipping it: %s' % (name, ex))
|
|
|
else:
|
|
else:
|
|
|
return (config, rm)
|
|
return (config, rm)
|
|
|
return None
|
|
return None
|