[
https://issues.apache.org/jira/browse/OOZIE-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14259324#comment-14259324
]
Harsh J commented on OOZIE-2102:
--------------------------------
Workaround for those affected by use of this change already would be to place
in something such as below into the action definition, to manually invoke the
MR action to act as Streaming actions:
{code}
<property>
<name>mapred.mapper.class</name>
<value>org.apache.hadoop.streaming.PipeMapper</value>
</property>
<property>
<name>mapred.reducer.class</name>
<value>org.apache.hadoop.streaming.PipeReducer</value>
</property>
<property>
<name>mapred.map.runner.class</name>
<value>org.apache.hadoop.streaming.PipeMapRunner</value>
</property>
<property>
<name>mapred.input.format.class</name>
<value>org.apache.hadoop.mapred.TextInputFormat</value>
</property>
<property>
<name>mapred.output.format.class</name>
<value>org.apache.hadoop.mapred.TextOutputFormat</value>
</property>
<property>
<name>mapred.output.value.class</name>
<value>org.apache.hadoop.io.Text</value>
</property>
<property>
<name>mapred.output.key.class</name>
<value>org.apache.hadoop.io.Text</value>
</property>
<property>
<name>stream.map.streamprocessor</name>
<value>${oozie.streaming.mapper}</value>
</property>
<property>
<name>oozie.streaming.reducer</name>
<value>${stream.reduce.streamprocessor}</value>
</property>
{code}
> Streaming actions are broken cause of incorrect method signature
> ----------------------------------------------------------------
>
> Key: OOZIE-2102
> URL: https://issues.apache.org/jira/browse/OOZIE-2102
> Project: Oozie
> Issue Type: Bug
> Components: action
> Affects Versions: trunk
> Reporter: Harsh J
> Assignee: Harsh J
> Priority: Blocker
>
> OOZIE-1954 changed the submitJob(Configuration) signature to
> submitJob(JobConf), but this change was not caught and made in the
> StreamingMain class cause it did not use an Override annotation.
> Streaming jobs no longer succeed on trunk as a result. Pipe jobs still do as
> the change was made in it instead.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
