我的工作流需要使用job.properties以外的其他文件。此文件的结构与属性文件相同。我有一个结果的路径生成器，它创建了这个文件。这种方法的特殊性在于，每次启动工作流时它都会发生变化（使用新的输入文件）。在我的工作流中，我需要在执行mys pig脚本之前删除这些路径。但是，我不知道如何“告诉”我的工作流，除了job.properties之外，我在另一个文件中还有其他变量。你有解决办法吗？谢谢安吉丽
pinkon5k1#
您可以删除pig中的路径，也可以在执行pig操作之前在工作流中调用fs操作，两者都可以工作。对于文件开头的rmf命令：rmf在工作流中：
<action name="prepare"> <fs> <delete path="${pig output}"/> </fs> <ok to="pigAction"/> <error to="prepareFailed"/> </action> <kill name="prepareFailed"> <message>Clean Action failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message> </kill>
1条答案
按热度按时间pinkon5k1#
您可以删除pig中的路径，也可以在执行pig操作之前在工作流中调用fs操作，两者都可以工作。
对于文件开头的rmf命令：rmf
在工作流中：