Как создать координатор Ooz ie по прибытии ввода несколько раз в день - PullRequest
Новая
       86

Как создать координатор Ooz ie по прибытии ввода несколько раз в день

0 голосов
/ 12 февраля 2020

У меня есть требование назначить моего координатора по прибытии ввода из другого приложения. Я могу получить один или несколько раз в день. Таким образом, всякий раз, когда я получаю информацию, мне нужно начать лечение. Может кто-нибудь помочь мне, как это сделать в Ooz ie координатор? Я пробовал с приведенным ниже кодом, но он работает только один раз в день, он не работает, даже если я получаю ввод после первой обработки. 

    <coordinator-app name="TEST_MASTER_C" frequency="${coord:days(1)}" start="${start_date}" end="${end_date}" timezone="Europe/Paris" xmlns="uri:oozie:coordinator:0.2" xmlns:sla="uri:oozie:sla:0.1">
  <controls>
    <timeout>1430</timeout>
    <execution>FIFO</execution>
  </controls>
  <datasets>
    <dataset name="inputFlag" frequency="${coord:days(1)}" initial-instance="${start_date}" timezone="Europe/Paris">
      <uri-template>@nameNode@/testpath</uri-template>
      <done-flag>${flag}</done-flag>
    </dataset>
  </datasets>
  <input-events>
    <data-in name="coordInputFlag" dataset="inputFlag">
      <instance>${coord:current(0)}</instance>
    </data-in>
  </input-events>
...