Hadoop MapReduce: 解决 "Illegal partition for 1660,1998-01-10 (-16)" 错误

package com.mystudy.pxkDazuoye;

import org.apache.hadoop.io.Text; import org.apache.hadoop.mapreduce.Partitioner;

public class FirstNamePartitioner extends Partitioner<Text, Text> { @Override public int getPartition(Text key, Text value, int numPartitions) { String firstName = key.toString().toUpperCase(); char firstLetter = firstName.charAt(0); int partitionNumber = (int) (firstLetter - 'A') % numPartitions; // 处理负数分区号的情况 if (partitionNumber < 0) { partitionNumber += numPartitions; } return partitionNumber; } }