怎么写一个动态传值的请假工作流
2017-06-16
展开全部
假设workflow里有两个action节点,shell和Hive,hive需要用到shell节点里的值,shell脚本如下
#!/bin/sh
day=`date '+%Y%m%d%H'`
echo "day:$day"
hive节点需传入day这个参数。需要用到shell节点里<capture-output/>这个属性,如下
<action name="shell-118a ">
<shell xmlns="uri:oozie:shell-action:0.1">
<job-tracker>${jobTracker}</job-tracker>
<name-node>${nameNode}</name-node>
<configuration>
<property>
<name>mapred.job.queue.name</name>
<value>${queueName}</value>
</property>
</configuration>
<exec>${shell}</exec>
<file>${shell}#${shell}</file>
<capture-output/>
</shell>
<ok to="hive_node "/>
<error to="fail"/>
</action>
<action name="hive_node">
<hive xmlns="uri:oozie:hive-action:0.2">
<job-tracker>${jobTracker}</job-tracker>
<name-node>${nameNode}</name-node>
<job-xml>${apps_hdfs_home}/common/conf/hive-site.xml</job-xml>
<script>${sql}</script>
<param>day=${wf:actionData('shell-118a')['day']}</param>
</hive>
<ok to="end"/>
<error to="Kill"/>
</action>
#!/bin/sh
day=`date '+%Y%m%d%H'`
echo "day:$day"
hive节点需传入day这个参数。需要用到shell节点里<capture-output/>这个属性,如下
<action name="shell-118a ">
<shell xmlns="uri:oozie:shell-action:0.1">
<job-tracker>${jobTracker}</job-tracker>
<name-node>${nameNode}</name-node>
<configuration>
<property>
<name>mapred.job.queue.name</name>
<value>${queueName}</value>
</property>
</configuration>
<exec>${shell}</exec>
<file>${shell}#${shell}</file>
<capture-output/>
</shell>
<ok to="hive_node "/>
<error to="fail"/>
</action>
<action name="hive_node">
<hive xmlns="uri:oozie:hive-action:0.2">
<job-tracker>${jobTracker}</job-tracker>
<name-node>${nameNode}</name-node>
<job-xml>${apps_hdfs_home}/common/conf/hive-site.xml</job-xml>
<script>${sql}</script>
<param>day=${wf:actionData('shell-118a')['day']}</param>
</hive>
<ok to="end"/>
<error to="Kill"/>
</action>
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
2017-06-16
展开全部
不管什么经理 总监 啥的
按等级
某等级有哪些 角色
某等级有哪些 权限
按等级
某等级有哪些 角色
某等级有哪些 权限
本回答被提问者采纳
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询