ozzie工作流fork-join操作共享具有相同名称的变量,或者它们有自己的副本

txu3uszq  于 2021-05-29  发布在  Hadoop
关注(0)|答案(0)|浏览(224)

我有一个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>

暂无答案!

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

相关问题