2016-02-05 74 views
0

我尝试了几天,开始与Oozie的Wordount(MapReduce)作业。与正常(CMD:“hadoop jar * .jar mainClass输入输出”)作业开始一切正常。当前Oozie的配置是:MapReduce开始的工作被杀死了。为什么?

  • /ApplicationDIR/lib/WordCount.jar
  • /ApplicationDIR/workflow.xml
  • /文字-IN
  • /文字-OUT

    workflow.xml

    <action name='wordcount'> 
        <map-reduce> 
         <job-tracker>${jobTracker}</job-tracker> 
         <name-node>${nameNode}</name-node> 
         <prepare> 
          <delete path="${outputDir}" /> 
         </prepare> 
         <configuration> 
    
          <property> 
           <name>mapred.job.queue.name</name> 
           <value>${queueName}</value> 
          </property> 
          <property> 
           <name>mapred.mapper.class</name> 
           <value>HadoopJobs.wordCound.WordCountMR.Map</value> 
          </property> 
          <property> 
           <name>mapred.reducer.class</name> 
           <value>HadoopJobs.wordCound.WordCountMR.Reduce</value> 
          </property> 
          <property> 
           <name>mapreduce.input.fileinputformat.inputdir</name> 
           <value>${inputDir}</value> 
          </property> 
          <property> 
           <name>mapreduce.output.fileoutputformat.outputdir</name> 
           <value>${outputDir}</value> 
          </property> 
         </configuration> 
        </map-reduce> 
        <ok to='end'/> 
        <error to='kill'/> 
    </action> 
    
    <kill name='kill'> 
        <message>ERROR: [${wf:errorMessage(wf:lastErrorNode())}]</message> 
    </kill> 
    
    <end name='end'/> 
    

job.properties

nameNode=hdfs://192.168.1.110:8020  
jobTracker=192.168.1.110:8050 
queueName=default 

oozie.wf.application.path=${nameNode}/tmp/testDIR/wordcount-example/ApplicationDIR 
inputDir=hdfs://192.168.1.110:8020/tmp/testDIR/wordcount-example/Text-IN 
outputDir=hdfs://192.168.1.110:8020/tmp/testDIR/wordcount-example/Text-OUT 

命令:

oozie job -oozie http://192.168.1.110:11000/oozie/ -config job.properties -run 

结果:

Job gets killed

--UPDATE--

Oozie的日志: https://docs.google.com/document/d/1BKnv4dSEscRqpzKLhOjUaryveSP3q0454uL_5_xVPdk/edit?usp=sharing

+0

可以共享Oozie的日志和作业服务器日志 –

+0

@KSNidhin我已经添加了Oozie日志。我也检查他们,但没有什么特别的。你能告诉我在哪里可以找到JobTracker日志吗? –

+0

为此,您必须打开JT UI并搜索JOB Action IF,您将从OOZIE UI自行获取它,并使用Analysis TAB查看Job Tracker Job,或者可以手动在本地mapred data.dir中搜索JOB ID错误的详细信息的位置 – Deb

回答

0

我通过下载Cloudera的CDH解决这个问题。他们有HUE,它有一个非常好的用户界面,在那里我可以看到我详细的错误。总之,我解决我的错误,当我从工作流程XML删除以下部分:

  <property> 
       <name>mapred.mapper.class</name> 
       <value>HadoopJobs.wordCound.WordCountMR.Map</value> 
      </property> 
      <property> 
       <name>mapred.reducer.class</name> 
       <value>HadoopJobs.wordCound.WordCountMR.Reduce</value> 
      </property> 
相关问题