Функции EL для Oozie done-flag

Я пытаюсь использовать встроенные функции или функции EL, предоставляемые oozie в теге oozie-coordinator xml, но, похоже, это не поддерживается? Кто-нибудь знает какой-либо другой способ заявить об этом?

Наши готовые флаги содержат даты.

<done-flag>${YEAR}${MONTH}${DAY}.done</done-flag>
OR
<done-flag>${coord:formatTime(coord:actualTime(), 'yyyyMMdd')}</done-flag>

Я получаю следующую ошибку при запуске рабочего процесса координатора oozie.

Error: E1004 : E1004: Expression language evaluation error, 
Unable to evaluate :${coord:formatTime(coord:actualTime(), 'yyyyMMdd')}:

Кто-нибудь знает способ добиться динамических имен флагов готовности?


oozie oozie-coordinator
person Pratik Khadloya    schedule 28.07.2015    source источник

Ответы (2)


arrow_upward
1
arrow_downward

Не уверен на 100%, что вы хотите сделать.

Насколько я понимаю, координатор ожидает файл с именем «флаг готовности» перед запуском рабочего процесса. Затем можно использовать функцию "coord:actualTime()", чтобы узнать, в какое время действительно был запущен рабочий процесс.

=> документацию следует подчеркнуть, что фраза "действие координатора" в большинстве случаев фактически означает "рабочий процесс"...

Если вы хотите проверить время на часах, пока координатор все еще ожидает, ключевые слова ГОД - МЕСЯЦ - ДЕНЬ - ЧАС - МИНУТА - ваша единственная надежда.

person Samson Scharfrichter    schedule 28.07.2015

arrow_upward
0
arrow_downward

Я заработал следующим образом, используя переменные YEAR, MONTH, DAY в шаблоне uri и очистив файл .

  <uri-template>
    /donemarkers/dependency-job/${YEAR}${MONTH}${DAY}.done
  </uri-template>
  <!--<done-flag>${YEAR}${MONTH}${DAY}.done</done-flag>-->
  <done-flag></done-flag>

Из журналов я узнал, что oozie сначала проверяет, существует ли каталог с именем, указанным в uri-template, если нет, то проверяет, существует ли файл, указанный в uri-template.

2015-07-28 19:40:46,225  INFO CoordActionInputCheckXCommand:539 - USER[-] GROUP[-] TOKEN[-] APP[-] JOB[0131647-140520191754742-oozie-oozi-C] ACTION[0131647-140520191754742-oozie-oozi-C@2] [0131647-140520191754742-oozie-oozi-C@2]::ActionInputCheck:: In checkResolvedUris...
2015-07-28 19:40:46,225  INFO CoordActionInputCheckXCommand:539 - USER[-] GROUP[-] TOKEN[-] APP[-] JOB[0131647-140520191754742-oozie-oozi-C] ACTION[0131647-140520191754742-oozie-oozi-C@2] [0131647-140520191754742-oozie-oozi-C@2]::ActionInputCheck:: In checkListOfPaths: /donemarkers/dependency-job/20150725.done is Missing.
2015-07-28 19:40:46,241  INFO CoordActionInputCheckXCommand:539 - USER[-] GROUP[-] TOKEN[-] APP[-] JOB[0131647-140520191754742-oozie-oozi-C] ACTION[0131647-140520191754742-oozie-oozi-C@2] [0131647-140520191754742-oozie-oozi-C@2]::ActionInputCheck:: File:/donemarkers/dependency-job/20150725.done, Exists? :true
person Pratik Khadloya    schedule 28.07.2015