hadoop - 将变量传递给 oozie 案例部分不起作用

Question

我有一个 oozie 动作，它具有以下节点。

工作节点::

 <decision name="CheckFilesSize">
        <switch>
            <case to="MoveStageToInbound">
              ${ fs:dirSize(&#39;s3://hadoopdev/data/processor_controller/outbound/raw_events&#39;) gt 1 * KB}
            </case>
            <case to="DoNothing">
            </case>
            <default to="end"/>
        </switch>
    </decision>

当我尝试使用 job.properties 中的可变值参数化使用的路径时，它不起作用。

<decision name="CheckFilesSize">
        <switch>
            <case to="MoveStageToInbound">
              ${ fs:dirSize(&#39;${bucket_name}/data/processor_controller/outbound/raw_events&#39;) gt 1 * KB}
            </case>
            <case to="DoNothing">
            </case>
            <default to="end"/>
        </switch>
    </decision>

我得到以下错误。

EL_ERROR 索引 0 处路径中的非法字符：{bucket_name}/data/processor_controller/outbound/raw_events

Answer 1

尝试像这样使用 -

 ${ fs:dirSize('$bucket_name/data/stbh/inbound/xml_element_orphans') gt 1 * KB}