IntelliJ에서 Mapreduce 작업이 실패했습니다

Question

IntelliJ 내부에서 Map-Reduce 작업을 실행하려고합니다. 이것은 내 러너 코드입니다

public class ViewCount extends Configured implements Tool{ 

    @Override 
    public int run(String[] args) throws Exception { 
     Configuration conf = this.getConf(); 


     Job job = Job.getInstance(conf); 
     job.setJobName("viewCount"); 
     job.setJarByClass(ViewCount.class); 

     job.setOutputKeyClass(Text.class); 
     job.setOutputValueClass(IntWritable.class); 

     job.setMapperClass(Map.class); 
     job.setReducerClass(Reduce.class); 

     Path inputFilePath = new Path(args[0]); 
     Path outputFilePath = new Path(args[1]); 

     FileInputFormat.addInputPath(job, inputFilePath); 
     FileOutputFormat.setOutputPath(job, outputFilePath); 

     return job.waitForCompletion(true) ? 0:1; 

    } 

    public static void main(String[] args) throws Exception { 

     int exitCode = ToolRunner.run(new ViewCount(), args); 
     System.exit(exitCode); 
    } 

작업을 다음 오류 메시지와 함께 빌드하지 못합니다.

error: incompatible types: Job cannot be converted to JobConf 
     FileOutputFormat.setOutputPath(job, outputFilePath); 

Apached 문서

이 방법은 실제로, 그래서 내가 뭘 잘못 일이 아닌 JobConf을 소요하는 것이 좋습니다?

Answer 1

클래스가 제공하는 패키지를 살펴보십시오. 패키지가 혼합되어있을 수 있으므로 Hadoop 버전에 따라 올바른 패키지의 TextInputFormat을 사용해야합니다. Hadoop 버전 2.x를 사용하는 경우 Hadoop 버전 1.x (맵핑 된 패키지를 가짐)와 비교하여 다른 클래스 (mapreduce 패키지에서)를 가져와야합니다.