2017-08-18 34 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