hive 命令行傳入參數

azkban實現任務重跑

我們執行sql的方式是將hql文件上傳到服務器本地。然后執行shell命令

hive -hivevar dt="2019-04-07" -f ./test_scheduler.hql

注：hive -e 是執行依據短sql，hive -f是執行hql文件

 

test_scheduler.hql的內容是需要執行的sql語句，參數的寫法如下圖：

select * from ods.test where dt = ${dt};

 

azkaban 傳入參數

1.配置job，如下，用 ${參數名} 傳入參數

type=command
dependencies=start
command= sh /data/etl/test/para_test.sh ${p}

2.上傳zip包，azkaban web，執行任務頁面傳入參數

執行頁面，選擇配置參數 Flow Parameters

寫入job中的參數名和 參數值

執行。
這樣就將參數從外部傳入azkaban，並最終作為hive sql的參數執行了。