Configuration conf = this.getConf(); YarnJob job = new YarnJob(conf, "MonMapReduce Job"); job.setJarByClass(TraitementDriver.class); job.setMapperClass(TraitementMapper.class); job.setReducerClass(TraitementReducer.class); job.setInputFormatClass(TextInputFormat.class); job.addInputPath(new Path(args[0])); job.setOutputFormatClass(TextOutputFormat.class); job.setOutputPath(new Path(args[1])); boolean success = job.waitForCompletion(true);