Ooz ie - запускать рабочий процесс каждый день или каждый час - PullRequest
Новая
       95

Ooz ie - запускать рабочий процесс каждый день или каждый час

1 голос
/ 14 апреля 2020

У меня есть рабочий процесс ooz ie (hive_insertion. xml), который выполняет файл .hive, который вставляет данные в таблицу. Рабочий процесс Ooz ie: 

<workflow-app xmlns = "uri:oozie:workflow:0.4" name = "simple-Workflow">
   <start to = "Insert_into_treatment_costs_table " />

   <action name = "Insert_into_treatment_costs_table">
      <hive xmlns = "uri:oozie:hive-action:0.4">
         <job-tracker> ${jobTracker} </job-tracker>
         <name-node> ${nameNode} </name-node>
         <script>hdfs_path_of_script/treatment_insert.hive’</script>
      </hive>
<!-- what should happen on success--!>      
      <ok to = "end" />
<!-- what should happen on failure--!>  
      <error to = "kill_job" />
   </action>
<!-- this is what happens on failure --!>   
   <kill name = "kill_job">
      <message>Job failed</message>
   </kill>
<!-- this is what happens on success --!>       
   <end name = "end" />

</workflow-app>

Это можно выполнить из каталога, в котором также находится файл 'hive_insertion. xml'. 

# sudo -u oozie oozie job –oozie

, где я могу внести изменения поэтому этот рабочий процесс выполняется в конце каждого дня.

1 Ответ

1 голос
/ 14 апреля 2020

Вы должны использовать Ooz ie Координатор для планирования рабочих процессов ooz ie.

Для выполнения в конце каждого дня используйте функцию EL ${coord:endOfDays(1)}

Включить определение рабочего процесса в действие координатора, 

<coordinator-app name="daily" frequency="${coord:endOfDays(1)}" start="${start}" end="${end}" 
                timezone="UTC" xmlns="uri:oozie:coordinator:0.1">
  <action>
     <workflow>
       ...
     </workflow>
  </action>
</coordinator-app>

Примечание: Ooz ie координатор также поддерживает Cron Syntax . Используйте его для более гибких частот.

...