【发布时间】:2016-12-18 18:36:51
【问题描述】:
我的协调器应用程序已成功读取输入事件并在标称时间执行工作流,但根本没有生成输出事件。
我尝试在没有完成标志的情况下设置输出事件,但它不起作用。我做错了什么?
下面是我的 coordinator.xml 文件。
<coordinator-app name="wf_scheduler" frequency="${coord:days(1)}"
start="2016-12-14T00:00Z" end="2016-12-19T00:00Z" timezone="IST"
xmlns="uri:oozie:coordinator:0.2">
<controls>
<timeout>30</timeout>
<concurrency>3</concurrency>
<execution>FIFO</execution>
<throttle>3</throttle>
</controls>
<datasets>
<dataset name="inp_logs" frequency="${coord:days(1)}"
initial-instance="2016-12-01T00:00Z" timezone="IST">
<uri-template>
/user/cloudera/inp_logs/${YEAR}_${MONTH}_${DAY}
</uri-template>
<done-flag></done-flag>
</dataset>
<dataset name="opt_logs" frequency="${coord:days(1)}"
initial-instance="2016-12-01T00:00Z" timezone="IST">
<uri-template>
/user/cloudera/opt_logs/${YEAR}_${MONTH}_${DAY}
</uri-template>
<done-flag>_trigger</done-flag>
</dataset>
</datasets>
<input-events>
<data-in name="input" dataset="inp_logs">
<instance>${coord:current(0)}</instance>
</data-in>
</input-events>
<output-events>
<data-out name="output" dataset="opt_logs">
<instance>${coord:current(0)}</instance>
</data-out>
</output-events>
<action>
<workflow>
<app-path>${app_path}</app-path>
</workflow>
</action>
</coordinator-app>
【问题讨论】: