我有一个ozzie fork join工作流,它有一个带有hr和day等变量的配置单元查询,并将它们传递给配置单元查询,这些操作是否会为查询执行创建单独的配置单元会话,或者存在变量覆盖的危险。
谢谢
<fork name = "fork_node">
<path start = "Create_local_Table-d00"/>
<path start = "Create_local_Table-d01"/>
<path start = "Create_local_Table-d02"/>
<path start = "Create_local_Table-d03"/>
<path start = "Create_local_Table-d04"/>
<path start = "Create_local_Table-d05"/>
<path start = "Create_local_Table-d06"/>
<path start = "Create_local_Table-d07"/>
<path start = "Create_local_Table-d08"/>
<path start = "Create_local_Table-d09"/>
<path start = "Create_local_Table-d10"/>
<path start = "Create_local_Table-d12"/>
<path start = "Create_local_Table-d13"/>
<path start = "Create_local_Table-d14"/>
<path start = "Create_local_Table-d15"/>
<path start = "Create_local_Table-d16"/>
<path start = "Create_local_Table-d17"/>
<path start = "Create_local_Table-d18"/>
<path start = "Create_local_Table-d19"/>
<path start = "Create_local_Table-d20"/>
<path start = "Create_local_Table-d21"/>
<path start = "Create_local_Table-d22"/>
<path start = "Create_local_Table-d23"/>
<path start = "Create_local_Table-d24"/>
<path start = "Create_local_Table-d00"/>
<path start = "Create_local_Table-d00"/>
<path start = "Create_orc_Table"/>
</fork>
<action name="loadDailyPartitionToLocalStaging" cred='hive_credentials'>
<hive xmlns="uri:oozie:hive-action:0.2">
<script>/data/acs/hch/equipBatch/workflows/DataCleanup/TestWorkflowQa/loadDailyPartitionToLocalStaging.hql</script>
<param>hiveconf:year=${year}</param>
<param>hiveconf:month=${month}</param>
<param>hiveconf:day=${day}</param>
<param>hiveconf:year_r=${year_r}</param>
<param>hiveconf:month_r=${month_r}</param>
<param>hiveconf:day_r=${day_r}</param>
<param>hiveconf:year_l=${year_l}</param>
<param>hiveconf:month_l=${month_l}</param>
<param>hiveconf:day_l=${day_l}</param>
<param>hiveconf:partitonDate=${partitonDate}</param>
<file>${wfpath}/TestWorkflowQa/tez-site.xml</file>
</hive>
<ok to="end" />
<error to="fail" />
</action>
<action name="loadDailyPartitionToLocalStaging" cred='hive_credentials'>
<hive xmlns="uri:oozie:hive-action:0.2">
<script>/data/acs/hch/equipBatch/workflows/DataCleanup/TestWorkflowQa/loadDailyPartitionToLocalStaging.hql</script>
<param>hiveconf:year=${year}</param>
<param>hiveconf:month=${month}</param>
<param>hiveconf:day=${day}</param>
<param>hiveconf:year_r=${year_r}</param>
<param>hiveconf:month_r=${month_r}</param>
<param>hiveconf:day_r=${day_r}</param>
<param>hiveconf:year_l=${year_l}</param>
<param>hiveconf:month_l=${month_l}</param>
<param>hiveconf:day_l=${day_l}</param>
<param>hiveconf:partitonDate=${partitonDate}</param>
<file>${wfpath}/TestWorkflowQa/tez-site.xml</file>
</hive>
<ok to="end" />
<error to="fail" />
</action>
暂无答案!
目前还没有任何答案,快来回答吧!