2016-05-16 3 views
1

У меня есть рабочий процесс с подчиненным документооборотом. «Основной» рабочий процесс проверяет размер файла каталога, и если размер больше значения триггера, запускается вспомогательный рабочий процесс.Найти время последнего выполнения рабочего процесса в oozie

Теперь мне нужен дополнительный триггер: время от текущего выполнения основного рабочего процесса и отметка времени последнего выполнения подзапроса. На данный момент я вижу только возможность записи временной метки в файле hdfs или таблице hive или в результате изменения вывода интерфейса командной строки oozie.

Кто-нибудь знает более элегантный способ решить эту проблему в рабочих файлах или файлах oozie?

+0

Дополнительные неэлементные варианты: исправление вывода Oozie REST API; запрос базового метасторе в SQL * (yuck) *. –

+0

Поскольку я не нашел более элегантного решения, я использую это как решение: 'oozie jobs -oozie $ {OOZIE_HOST}/oozie -localtime -len 1 -filter name = $ {WORKFLOW} | grep $ {WORKFLOW} | rev | cut -c -25 | rev | sed -e 's/[^ 0-9] // g'' .. Если что-то пойдет не так, или рабочий процесс не найден, результат будет нулевым, что соответствует моменту –

ответ

0

Поскольку я не нашел более элегантного решения, я использую это как решение: oozie jobs -oozie $ {OOZIE_HOST}/oozie -localtime -len 1 -filter name = $ {WORKFLOW} | grep $ {WORKFLOW} | rev | cut -c -25 | rev | sed -e 's/[^ 0-9] // g' .. Если что-то пойдет не так, или рабочий процесс не найден, результат будет нулевым, что нормально в данный момент

Смежные вопросы