2017-08-18 53 views
0

我的用例如下,我正在構建一個Oozie管道,我需要將它傳遞給一個參數。如何將參數傳遞給Oozie

事實上,我的spark工作必須收到一個字符串日期作爲參數,將參數傳遞給Oozie工作流以便在Spark提交中使用該參數會很好。任何人有任何想法?我沒有找到在谷歌的答案

感謝

+1

您可以在屬性文件中的運行時替換日期,並將屬性文件中定義的變量作爲參數傳遞給spark。 – philantrovert

+0

感謝您的答案,但它不完全是我要找的,因爲我想作爲參數傳遞任何日期,而不僅僅是當前日期與運行時。 – lucienfregosi

回答

1
  1. 創建workflow.xml引用一些變量inputDate

  2. 創建定義inputDate

  3. 默認值 文件job.properties
  4. 使用CLI運行 您的工作,需要時覆蓋默認值:
    oozie job -run -config job.properties -DinputDate=2017-08-19