注意:上面的例子中pi.py必须是spark教程菜鸟教程的本地文件!这个python文件应该放在靠近workflow.xml的lib/目录下或者将文件前面加上详细的地址。
Oozie除了可以使用Properties文件定义一些属性之外还提供了一些内置的EL函数,能够方便地实现流程的定义和控制下面我们分组列表说明:
下面是一个在实际工程中使用的例子: