hadoop - 执行时 java.lang.ArrayIndexOutOfBoundsException

Question

package com.HadoopExpert;


import java.io.IOException;

import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;


  public class SumMapper extends Mapper<LongWritable, Text,Text,IntWritable>{


  public void map(LongWritable key, Text value, Context con) throws IOException, InterruptedException{

    String s = value.toString();
    String[] words = s.split(",");

    String gender  = words[4];
    int sal = Integer.parseInt(words[2]);

    con.write(new Text(gender), new IntWritable(sal));
}
}

这是我的映射器类代码我想通过索引获取数组 m 得到一个错误数组超出了索引
提前谢谢

Answer 1

根据您评论中提到的数据，性别的索引应该是3 .注意数组的索引从0开始在 java 。

您应该在使用前检查您的数据，例如:

if (words.length > 3) {
    String gender = words[3];
    ......
}

您应该考虑如何处理不良数据(计数然后忽略它，或者尝试修复它，等等)。