|
@@ -936,6 +936,8 @@ def parse_out_jobs(log, engine='mr', with_state=False):
|
|
|
start_pattern = SPARK_APPLICATION_RE
|
|
start_pattern = SPARK_APPLICATION_RE
|
|
|
elif engine.lower() == 'tez':
|
|
elif engine.lower() == 'tez':
|
|
|
start_pattern = TEZ_APPLICATION_RE
|
|
start_pattern = TEZ_APPLICATION_RE
|
|
|
|
|
+ elif engine.lower() == 'impala':
|
|
|
|
|
+ return ret
|
|
|
else:
|
|
else:
|
|
|
raise ValueError(_('Cannot parse job IDs for execution engine %(engine)s') % {'engine': engine})
|
|
raise ValueError(_('Cannot parse job IDs for execution engine %(engine)s') % {'engine': engine})
|
|
|
|
|
|