Caused by: java.lang.NullPointerException
at org.apache.hadoop.io.Text.encode(Text.java:450)
at org.apache.hadoop.io.Text.set(Text.java:198)
at org.apache.hadoop.io.Text.(Text.java:88)
at com.imooc.bigdata.project.mrv2.ProvinceStatV2App$MyMapper.map(ProvinceStatV2App.java:84)atcom.imooc.bigdata.project.mrv2.ProvinceStatV2App$MyMapper.map(ProvinceStatV2App.java:68)
at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:146)
at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:787)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:341)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:270)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)atjava.util.concurrent.FutureTask.run(FutureTask.java:266)atjava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)atjava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
[INFO ] method:org.apache.hadoop.mapreduce.Job.monitorAndPrintJob(Job.java:1431)
Job job_local909125896_0001 failed with state FAILED due to: NA
[INFO ] method:org.apache.hadoop.mapreduce.Job.monitorAndPrintJob(Job.java:1436)
Counters: 0

附代码：
public class ProvinceStatV2App {

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

    Configuration configuration = new Configuration();
    FileSystem fileSystem= FileSystem.get(configuration);
    Path outputPath = new Path("output/v2/provincestat");
    if(fileSystem.exists(outputPath)){
        fileSystem.delete(outputPath,true);
    }

    Job job = Job.getInstance(configuration);
    job.setJarByClass(ProvinceStatV2App.class);

    //设定Mapper类
    job.setMapperClass(MyMapper.class);
    //设定Reduce类
    job.setReducerClass(MyReducer.class);

    //输出map key的类
    job.setMapOutputKeyClass(Text.class);

    //输出map value的类型
    job.setMapOutputValueClass(LongWritable.class);

    //输出Reduce key的类型
    job.setOutputKeyClass(Text.class);
    //输出Reduce  value的类型
    job.setOutputValueClass(LongWritable.class);

    //设置输入路径
    FileInputFormat.setInputPaths(job, new Path("input/etl"));
    //设置输出路径
    FileOutputFormat.setOutputPath(job, new Path("output/v2/provincestat"));

    //任务完成
    job.waitForCompletion(true);

}

static class MyMapper extends Mapper<LongWritable,Text,Text,LongWritable>{
    private LogParser logParser;
    private LongWritable ONE = new LongWritable(1);

    @Override
    protected void setup(Context context) throws IOException, InterruptedException {
        logParser = new LogParser();
    }

    @Override
    protected void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {
        String log = value.toString();

        Map<String,String> info = logParser.parsev2(log);


        context.write(new Text(info.get("province")),ONE);

    }

}
static  class MyReducer extends Reducer<Text,LongWritable,Text,LongWritable>{
    @Override
    protected void reduce(Text key, Iterable<LongWritable> values, Context context) throws IOException, InterruptedException {
        long count = 0;
        for(LongWritable value : values){
            count ++;
        }
        context.write(key, new LongWritable(count));
    }
}

}