oozie协调器条件输入事件

f0brbegy  于 2021-05-31  发布在  Hadoop
关注(0)|答案(0)|浏览(231)

my oozie coordinator.xml有一个输入数据集,并在执行前等待同一日期的标志被写入:

<datasets>
  <dataset name="data" frequency="${coord:days(1)}" initial-instance="${startTime}" timezone="UTC">
    <uri-template>flags_dir/${YEAR}-${MONTH}-${DAY}</uri-template> 
    <done-flag>OK</done-flag> 
  </dataset>
</datasets> 

<input-events>    
  <data-in name="coordInput_data" dataset="data">   
    <instance>${coord:current(0)}</instance>
  </data-in>
</input-events>

对于2020年的数据集 data 是相关的,但是对于2019年,数据集不存在,并且此协调器触发的进程不需要它。
有没有一种方法可以 data 仅当协调人的名义日期为2020年时,才与协调人相关?i、 例如 max(coord:current(0), "2020-01-01") .

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题