背景：
簡單介紹下 hive action的使用，以及action間是如何進行引數傳遞的，這也是進行多job排程必備的操作~

叢集環境：CDH 5.13.0 ，其中oozie版本：4.1.0，hive版本：1.1.0

一、Hue配置 Hive action

hue上建立hive任務必須新增兩個配置項：script 和 hive xml

其中：
script 指的是hive sql 指令碼，
hive xml 指的是hive-site.xml（該檔案在CDH叢集中每臺機器的/etc/hive/conf目錄下）

我們將 hive-site.xml 檔案上傳到 hdfs：

hadoop fs -put
 
 /etc/hive/conf/hive-site.xml /yj/

配置完直接執行即可，hive action一般沒啥坑~

附上workflow.xml：

<workflow-app name="hiveshell-test2" xmlns="uri:oozie:workflow:0.5">
    <start to="hive-a0d5"/>
    <kill name="Kill">
        <message>Action failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message
 
>
    </kill>
    <action name="hive-a0d5" cred="hcat">
        <hive xmlns="uri:oozie:hive-action:0.2">
            <job-tracker>${jobTracker}</job-tracker>
            <name-node>${nameNode}</name-node>
            <job-xml>/yj/hive-site.xml</job-xml>
 

            <script>/yj/hive_script3.hql</script>
        </hive>
        <ok to="End"/>
        <error to="Kill"/>
    </action>
    <end name="End"/>
</workflow-app>

二、action間引數傳遞

我們在根據業務需求配置workflow.xml時，經常需要將上一個action得出的結果作為引數傳遞給下一個action，這種需求如何實現呢？

我們首先要明確的是：
hive action之間不支援傳遞引數，我們可以通過在shell 指令碼中hive -e執行hql獲取結果，再由shell傳遞給下一個hive action

目前我測試成功的有shell action中輸出，然後在下一個hive action 或 shell action 接受上一個shell action 的輸出結果；關於spark等其他action以後有時間在研究吧！

引數傳送方(shell action)：

先建立shell指令碼 hive_script1：

# !/bin/bash
hive_test_count=`hive -e "select count(1) from house.h_apply"`
echo "hive_test_count=${hive_test_count}"

將其shell指令碼配置到 shell action 作為結果引數傳送方，然後在workflow.xml中新增<capture-output/>屬性；

注：新增<capture-output/>元素可以捕獲shell指令碼的標準輸出，然後在另一個action中裡通過el表示式獲取：${wf:actionData('shell action1').hive_test_count} 或 ${wf:actionData('shell action1')['hive_test_count']}

hue介面只需要勾選就行了！預設都是勾選好的！

1.引數接收方(shell action)：

在shell-f704中新增<argument>值：

<argument>
    ${wf:actionData('shell-d412').hive_test_count}
</argument>

然後在該shell指令碼hive_script2中獲取：

# !/bin/bash
echo "aaaaa $1"

通過$數字來獲取！

hue配置：

附上workflow.xml：

<workflow-app name="hiveshell-test1" xmlns="uri:oozie:workflow:0.5">
    <start to="shell-d412"/>
    <kill name="Kill">
        <message>Action failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message>
    </kill>
    <action name="shell-d412">
        <shell xmlns="uri:oozie:shell-action:0.1">
            <job-tracker>${jobTracker}</job-tracker>
            <name-node>${nameNode}</name-node>
            <exec>/yj/hive_script1</exec>
            <file>/yj/hive_script1#hive_script1</file>
              <capture-output/>
        </shell>
        <ok to="shell-f704"/>
        <error to="Kill"/>
    </action>
    <action name="shell-f704">
        <shell xmlns="uri:oozie:shell-action:0.1">
            <job-tracker>${jobTracker}</job-tracker>
            <name-node>${nameNode}</name-node>
            <exec>/yj/hive_script2</exec>
              <argument>${wf:actionData('shell-d412').hive_test_count}</argument>
            <file>/yj/hive_script2#hive_script2</file>
              <capture-output/>
        </shell>
        <ok to="End"/>
        <error to="Kill"/>
    </action>
    <end name="End"/>
</workflow-app>

2.引數接收方(hive action)：

在hive-a0d5中的workflow.xml裡新增：

<param>
    COUNT=${wf:actionData('shell-d412').hive_test_count}
</param>

然後在hql指令碼 hive_script3.hql中新增：

select ${COUNT}

hue配置：

附上workflow.xml：

<workflow-app name="hiveshell-test2" xmlns="uri:oozie:workflow:0.5">
    <start to="shell-928d"/>
    <kill name="Kill">
        <message>Action failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message>
    </kill>
    <action name="shell-928d">
        <shell xmlns="uri:oozie:shell-action:0.1">
            <job-tracker>${jobTracker}</job-tracker>
            <name-node>${nameNode}</name-node>
            <exec>/yj/hive_script1</exec>
            <file>/yj/hive_script1#hive_script1</file>
              <capture-output/>
        </shell>
        <ok to="hive-a0d5"/>
        <error to="Kill"/>
    </action>
    <action name="hive-a0d5" cred="hcat">
        <hive xmlns="uri:oozie:hive-action:0.2">
            <job-tracker>${jobTracker}</job-tracker>
            <name-node>${nameNode}</name-node>
            <job-xml>/yj/hive-site.xml</job-xml>
            <script>/yj/hive_script3.hql</script>
            <param>COUNT=${wf:actionData('shell-928d').hive_test_count}</param>
        </hive>
        <ok to="End"/>
        <error to="Kill"/>
    </action>
    <end name="End"/>
</workflow-app>