我的map（）函数在代码执行期间似乎根本没有被调用，我不明白为什么。下面是我的工作课。。。

public class MyHadoopJob extends Configured implements Tool{

static class MyMapper extends Mapper<LongWritable, Text, LongWritable, Text>{

    public MyMapper(){
        System.out.println("Mapper init!");
    }

    @Override
    protected void map(LongWritable key, Text value,
                       org.apache.hadoop.mapreduce.Mapper<LongWritable, Text, LongWritable, Text>.Context context)
            throws java.io.IOException, InterruptedException {
        System.out.println("MAP!");
        context.getCounter("mygroup", "jeff").increment(1);
        context.write(key, value);
    };
}

@Override
public int run(String[] strings) throws Exception {

    Configuration conf = MYOBJ.getHadoopConf();
    this.setConf(conf);

    Job job = new Job(conf, "MyJob");
    job.setJarByClass(MyHadoopJob.class);
    job.setMapperClass(MyMapper.class);
    job.setOutputKeyClass(Text.class);
    job.setOutputValueClass(Text.class);
    job.setMapOutputKeyClass(LongWritable.class);
    job.setMapOutputValueClass(Text.class);

    FileInputFormat.setInputPaths(job, new Path(strings[0]));
    FileOutputFormat.setOutputPath(job, new Path(strings[1]));

    job.waitForCompletion(true);

    for(int i = 0; i < 10; i++){
        log.info("Progress -> " + job.mapProgress());
        Thread.sleep(15000);
    }

    return 0;
    }

}

如果能帮我弄清楚为什么map（）类或者类初始化从来没有被调用，我会非常感激？