Help in Decision making counters from MR job

[Bhagaban Khatai]

Hello,

Here is the Oozie workflow. If the MAP_INPUT_RECORDS is 20 then start the
Shell1 node. But it's not working it seems. I have mentioned the logs and
as well as the XML for your refercence, your quick help would be greatly
appriciated.

>From Hadoop Logs:

{(org\.apache\.hadoop\.mapreduce\.TaskCounter)(org\.apache\.hadoop\.mapreduce\.TaskCounter)[
*(MAP_INPUT_RECORDS)(MAP_INPUT_RECORDS)(20)][*
(MAP_OUTPUT_RECORDS)(MAP_OUTPUT_RECORDS)(0)][(MAP_OUTPUT_BYTES)(MAP_OUTPUT_BYTES)(0)][(MAP_OUTPUT_MATERIALIZED_BYTES)(MAP_OUTPUT_MATERIALIZED_BYTES)(6)][(SPLIT_RAW_BYTES)(SPLIT_RAW_BYTES)(136)][(COMBINE_INPUT_RECORDS)(COMBINE_INPUT_RECORDS)(0)][(COMBINE_OUTPUT_RECORDS)(COMBINE_OUTPUT_RECORDS)(0)][(SPILLED_RECORDS)(SPILLED_RECORDS)(0)][(CPU_MILLISECONDS)(CPU_MILLISECONDS)(580)]


oozie xml:

<ok to="mydecision"/>
        <error to="fail"/>
    </action>
<decision name="mydecision">
        <switch>
            <case to="Shell1">

${hadoop:counters('qualitycheck')["TaskCounter"][MAP_INPUT_RECORDS] eq 20}
            </case>
            <default to="fail"/>
        </switch>
    </decision>


Regards,
Bhagaban