diff --git a/src/mapred/org/apache/hadoop/mapred/lib/TotalOrderPartitioner.java b/src/mapred/org/apache/hadoop/mapred/lib/TotalOrderPartitioner.java index 7d69f92..9cdbaa8 100644 --- a/src/mapred/org/apache/hadoop/mapred/lib/TotalOrderPartitioner.java +++ b/src/mapred/org/apache/hadoop/mapred/lib/TotalOrderPartitioner.java @@ -95,7 +95,7 @@ public class TotalOrderPartitioner // by construction, we know if our keytype @SuppressWarnings("unchecked") // is memcmp-able and uses the trie public int getPartition(K key, V value, int numPartitions) { - return partitions.findPartition(key); + return partitions.findPartition(value); } /**