Я пытаюсь запустить поток Oozie (v4.3.0), в одном из моих заданий у меня есть несколько входов и несколько картографов для каждого входа. Вот как это выглядит в классе Driver:
MultipleInputs.addInputPath(job, new Path(args[0]), TextInputFormat.class, LeftMapper.class);
MultipleInputs.addInputPath(job, new Path(args[1]), TextInputFormat.class, RightMapper.class);
Но в Oozie workflow.xml это может выглядеть так, согласно это и это< /а>:
<property>
<name>mapred.input.dir.mappers</name>
<value>
${left};com.pge.mapreduce.join.LeftMapper,${right};com.pge.mapreduce.join.RightMapper
</value>
</property>
<property>
<name>mapred.input.dir.formats</name>
<value>
${left};org.apache.hadoop.mapreduce.lib.input.TextInputFormat,${right};org.apache.hadoop.mapreduce.lib.input.TextInputFormat
</value>
</property>
Но это не работает для меня, я получаю ошибку
В задании не указаны входные пути
UPD
job.properties
:
nameNode=maprfs:///
jobTracker=maprfs:///
queueName=default
examplesRoot=demo-flow
userName=mapr
left=${nameNode}/user/${userName}/${examplesRoot}/left.csv
right=${nameNode}/user/${userName}/${examplesRoot}/right.csv
mapred
устарели hadoop.apache .org/docs/r2.7.3/hadoop-project-dist/hadoop-common/ - person OneCricketeer   schedule 11.03.2018left
илиright
или какargs
передается в действие Java. - person OneCricketeer   schedule 11.03.2018mapred.input.dir.mappers
иmapred.input.dir.formats
установлены правильно - person Markiza   schedule 11.03.2018new Path(args[0])
назначается чему-либо. Можете ли вы показать полное действие Java Oozie? - person OneCricketeer   schedule 12.03.2018