java - 我们可以在 oozie 决策节点中使用参数吗?

标签 java hadoop oozie

我正在尝试在 oozie 3.3.2 中执行一个决策控制节点,但出现 javax.servlet.jsp.el.E​​LException

遇到“{”

<decision name="decision-wf">
 <switch>
           <case to="another_wf">
                ${fs:fileSize(${OutputDir}/000000_0) gt 100 }
           </case>

           <default to="fail-wf"/>
</switch>

我应该如何传递字符串格式的参数,因为上面提到的 FS 方法需要字符串输入?

最佳答案

来自document看来,

您需要通过硬编码,即包含在 ' 中就像在${fs:fileSize('/usr/foo/myinputdir'/1000) gt 10 }

只是参数名${fs:fileSize(OutputDir/1000) gt 10 }

OutputDir可能在 <config> 中指定工作流程的各个部分或 .properties文件或在使用 -D 提交作业时通过

关于java - 我们可以在 oozie 决策节点中使用参数吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/21730212/

相关文章:

java - 从文件配置 ehcache

hadoop - 使用函数替换 NULL

hadoop - Oozie 工作流中的多个 JAVA 操作

hadoop - Oozie作业由于模拟错误而无法运行(通配符支持)

hadoop - 在 Oozie 电子邮件操作中添加 html 标签

java - 有谁知道如何实现类似于Google App Engine 的白名单类访问方法?

java - 多对一选择语句?

java - 同步块(synchronized block)中的 HashMap 与 Collections.synchronizedMap() 之间有什么区别?

hadoop - 如何使用 sqoop 在 Hive 中创建外部表。需要建议

hadoop - 带有 Yarn 的 Spark Shell - 错误 : Yarn application has already ended! 它可能已被杀死或无法启动应用程序主机