2016-03-08 50 views
0

我安装了OOZIE并且可以运行它,但是我又遇到了OOZIE和我的项目的另一个问题: Java代码正常工作,但是当我尝试在Oozie中实现时,它不起作用任何更多。 Oozie中的地图相位输出规范有些问题,但我不知道是什么。

我的jar文件(名称wordcount1.jar)包括:
--JoinMapper $ MovieMapper
--JoinMapper $ FigureMapper
--JoinReducer
Oozie Reduce Join不起作用

这是我的错误日志:
2016- 03-09 01:24:30,441 INFO CallbackServlet:539 - USER [ - ] GROUP [ - ] TOKEN [ - ] APP [ - ] JOB [0000017-160308222246102-oozie-oozi-W]操作[0000017-160308222246102-oozie-oozi -W @ wordcount1]回复行动[0000017-160308222246102-oozie-oozi-W @ wordcount1]
2016-03-09 01:24:30,812 INFO MapReduceActionExecutor:539 - USER [training] GR [0000017-160308222246102-oozie-oozi-W]动作[0000017-160308222246102-oozie-oozi-W @ wordcount1]动作完成,外部ID [作业_201603082221_0037]
2016 -03-09 01:24:30,912警告MapReduceActionExecutor:542 - USER [training] GROUP [ - ] TOKEN [] APP [example-workflow]作业[0000017-160308222246102-oozie-oozi-W]作业[0000017-160308222246102-oozie -oozi-W @ wordcount1]启动器ERROR,原因:主类[org.apache.oozie.action.hadoop.MapReduceMain],main()引发异常,null
2016-03-09 01:24:31,120 INFO ActionEndXCommand: 539 - USER [培训] GROUP [ - ] TOKEN [] APP [示例 - 工作流程]作业[0000017-160308222246102-oozie-oozi-W]操作[0000017-160308222246102-oozie-oozi-W @ wordcount1]错误被认为是FAILED SLA
2016-03-09 01:24:31,250 INFO ActionStartXCommand:539 - USER [training] GROUP [ - ]标记[] APP [例如工作流] JOB [0000017-160308222246102-Oozie的-oozi-W] ..

我有以下job.properties文件:

nameNode=hdfs://localhost:8020 
jobTracker=localhost:8021 
queueName=default 
examplesRoot=joinoozie 
oozie.use.system.libpath=true 
oozie.wf.application.path=${nameNode}/user/training/${examplesRoot} 
inputDir1=movies1 
inputDir2=figures1 

我workflow.xml文件如下:
<workflow-app name="example-workflow" xmlns="uri:oozie:workflow:0.4"> <start to="wordcount1" /> <!-- WordCount MapReduce job --> <action name="wordcount1"> <map-reduce> <job-tracker>${jobTracker}</job-tracker> <name-node>${nameNode}</name-node> <prepare>
</prepare> <configuration> <property> <name>mapred.mapper.new-api</name> <value>true</value> </property> <property> <name>mapred.reducer.new-api</name> <value>true</value> </property>
<property> <name>mapred.job.queue.name</name> <value>${queueName}</value> </property>
<property> <name>mapreduce.inputformat.class</name> <value>org.apache.hadoop.mapreduce.lib.input.DelegatingInputFormat</value> </property> <property> <name>mapreduce.map.class</name> <value>org.apache.hadoop.mapreduce.lib.input.DelegatingMapper</value> </property> <property> <name>mapreduce.input.multipleinputs.dir.formats</name> <value>${inputDir1};org.apache.hadoop.mapred.TextInputFormat,${inputDir2};org.apache.hadoop.mapred.TextInputFormat</value> </property>
<property> <name>mapreduce.input.multipleinputs.dir.mappers</name> <value>${inputDir1};JoinMapper$MovieMapper,${inputDir2};JoinMapper$FigureMapper</value> </property>
<property> <name>mapreduce.reduce.class</name> <value>JoinReducer</value> </property>
<property> <name>mapred.output.dir</name> <value>output_oozie</value> </property> </configuration> </map-reduce>
<ok to="end" /> <error to='end'/> </action> <end name="end" /> </workflow-app>

请问有人可以帮我解决这个问题吗?会很好..
谢谢, Andi

+0

我发现了一条提示:“actionConf需要用WF Job默认配置复制。” - 有人知道actionConf需要存储在哪里吗? –

回答

0

Oozie提供了一组默认的属性,对应于工作流中的不同操作类型。你可以阅读更多关于位置和设置属性的顺序here

+0

谢谢..帮助 –

+0

如果答案有帮助,你可以upvote并将其标记为答案?它可能会帮助其他遇到类似问题的人。 – rahulbmv