Permalink
Browse files

MAPREDUCE-3139. Merge from trunk to 0.22.

  • Loading branch information...
1 parent 7bd0cfb commit 2b6fd44f6b927bcb6e0eed362bcb6adf0d3a646e @jghoman jghoman committed Nov 2, 2011
@@ -629,6 +629,8 @@ Release 0.22.0 - Unreleased
MAPREDUCE-2328. Add memory-related configuration parameters to
mapred-default.xml. (Harsh J via shv)
+ MAPREDUCE-3139. SlivePartitioner generates negative partitions. (jghoman)
+
Release 0.21.1 - Unreleased
NEW FEATURES
@@ -34,6 +34,6 @@ public void configure(JobConf conf) {}
@Override // Partitioner
public int getPartition(Text key, Text value, int numPartitions) {
OperationOutput oo = new OperationOutput(key, value);
- return oo.getOperationType().hashCode() % numPartitions;
+ return (oo.getOperationType().hashCode() & Integer.MAX_VALUE) % numPartitions;
}
}

0 comments on commit 2b6fd44

Please sign in to comment.