還原器沒有在hadoop中執行

Question

嗨iam對這個hadoop非常陌生，iam試圖執行一個簡單的mapreduce作業鏈，但是在我的代碼還原器中沒有執行。這裏有我寫的簡單代碼

這是我的映射器代碼 ​​

這是我簡單的減速碼

@Override 
public void reduce(Text arg0, Iterator<IntWritable> arg1, 
     OutputCollector<Text, IntWritable> arg2, Reporter arg3) 
     throws IOException { 
    // TODO Auto-generated method stub 
    System.out.println("in reducer"); 

} 

這是一個運行工作主類

JobConf jobConf = new JobConf(jobrunner.class); 
jobConf.setJobName("Chaining"); 

FileInputFormat.setInputPaths(jobConf, new Path("hdfs://localhost:9000/employee_data.txt")); 
FileOutputFormat.setOutputPath(jobConf,new Path("hdfs://localhost:9000/chain3.txt")); 

JobConf conf1 = new JobConf(false); 

ChainMapper.addMapper(jobConf,chainmap.class,LongWritable.class,Text.class,Text.class,IntWritable.class,true,conf1); 

JobConf conf2 = new JobConf(false); 

ChainReducer.setReducer(jobConf, chainreduce.class,Text.class,IntWritable.class,Text.class,IntWritable.class,true,conf2); 

JobClient.runJob(jobConf); 

不知道在哪裏IM在減速會wrong.the系統輸出未在此得到printed.any幫助？

Answer 1

可能的原因：您並沒有從映射器輸出任何東西，以便減速器首先運行。嘗試使用映射器中的outputCollector.collect(key, value);爲減速器寫入實際運行的內容。