将 Oozie 协调器的运行日期传播到工作流中

Question

问题总结

当运行一个 Oozie 协调员时，我需要工作流能够以 [=14] 的格式访问当前日期（即协调员运行的日期） =].

信息

我有一个由协调器初始化的大型 Oozie 工作流。

coord.properties

nameNode=<namenode>
jobTracker=<jobtracker>:8050

queueName=default
oozie.use.system.libpath=true
oozie.libpath=${nameNode}/project/workflow/lib
oozie.coord.application.path=${nameNode}/project/workflow

coordinator.xml:

<?xml version="1.0" encoding="UTF-8"?>
<coordinator-app xmlns="uri:oozie:coordinator:0.1" name="wf_scheduler" frequency="${coord:days(1)}" start="2015-01-30T08:50Z" end="2017-01-30T05:00Z" timezone="UTC">
   <action>
      <workflow>
         <app-path>${nameNode}/project/workflow</app-path>
         <configuration>
            <property>
               <name>currentDate</name>
               <value>${coord:actualTime()}</value>
            </property>
            <property>
            <name>runDate</name>
            <value>${convertDate(currentDate,"YYYY-MM-DDTHH:mmZ","yyyyMMdd")}</value>
            </property>
         </configuration>
      </workflow>
   </action>
</coordinator-app>

当运行这个工作流程来自 job.properties（即不是协调员）时，我在 job.properties 中有一个 runDate=20150125 属性。显然，当来自协调员的运行时，我需要让协调员每天设置 runDate。这看起来微不足道，但我找不到解决方案。

我已经有一个在 oozie.service.ELService.ext.functions.workflow 中提到的 EL 函数，它允许我给出表示日期的字符串、日期格式和所需的输出格式，然后 returns 中的字符串日期那个格式。即 ${convertDate("20150125", "yyyyMMdd", "yyyy-MM-dd") = 2015-01-25。当 job.properties 中的运行时，此功能完美运行，我的理想解决方案是能够在 coordinator.xml 中使用它。但是，提交协调器时出现以下错误：

Error: E1004 : E1004: Expression language evaluation error, Unable to evaluate :${convertDate(currentDate,"YYYY-MM-DDTHH:mmZ","yyyyMMdd")}:

Answer 1

您可能会发现使用内置 EL 函数 coord:formatTime(String timeStamp, String format) 转换时间戳格式更容易：

https://oozie.apache.org/docs/4.1.0/CoordinatorFunctionalSpec.html#a6.9.2._coord:formatTimeString_ts_String_format_EL_Function_since_Oozie_2.3.2

例如：

${coord:formatTime(coord:actualTime(), "yyyyMMdd")}

将 Oozie 协调器的运行日期传播到工作流中

Propagating an Oozie coordinator's run date into the workflow

hadoop

oozie

oozie-coordinator

将 Oozie 协调器的 运行 日期传播到工作流中

Propagating an Oozie coordinator's run date into the workflow

hadoop

oozie

oozie-coordinator

将 Oozie 协调器的运行日期传播到工作流中