（免责声明：我对hadoop和java非常陌生）
作为输入，有一个具有简单键值结构的表：

key1  value1
key2  value2
key3  value3
key2  value4
key1  value5
key1  value6

作为输出，我想为每个键收集属于特定键的所有值，如下所示：

key1, value1 value5 value6
key2, value2 value4
key3, value3

这是我的Map：

public class WordMapper extends Mapper<Object, Text, Text, Text> {

 @Override
 public void map(Object key, Text value,
   Context context) throws IOException, InterruptedException {

    String[] fields = value.toString().split("\\t", -1); 
    for (int i = 0; i < fields.length; ++i) {
        if ("".equals(fields[i])) fields[i] = null;
    }
    List<String> fields_list = Arrays.asList(fields);
    Text textKey = new Text(fields_list.get(0));
    Text textValue = new Text(fields_list.get(1));
    context.write(textKey,textValue);
    }
 }

这是减速器：

public class SumReducer extends Reducer<Text, TextArrayWritable, Text, TextArrayWritable> {
    private TextArrayWritable valuesTotal = new TextArrayWritable();

    public void reduce(Text key, Iterable<Text> values, Context context)
                throws IOException, InterruptedException {
        ArrayList<Text> values_list = new ArrayList<Text>();

        for (Text value : values) {
             values_list.add(value);
    }
        Text[] values_arr = new Text[values_list.size()];
        values_arr = values_list.toArray(values_arr);

         valuesTotal.setFields(values_arr);
         context.write(key, valuesTotal);
}
}

由于某种原因，我无法从我的程序中获得任何输出。它只是终止，在输出文件夹中没有留下任何内容。我有什么问题？
（我使用hadoop2.2.0和eclipse+hadoop插件。wordcount示例运行正常。）