actually fix it

This commit is contained in:
nishantmonu51 2014-04-08 20:08:21 +05:30
parent c6f531168f
commit 12991a959a
1 changed files with 3 additions and 3 deletions

View File

@ -52,9 +52,9 @@ public class HashBasedNumberedShardSpec extends NumberedShardSpec
public boolean isInChunk(InputRow inputRow)
{
int hash = Math.abs(hash(inputRow));
// if (hash == Integer.MIN_VALUE) {
// hash = 0;
// }
if (hash == Integer.MIN_VALUE) {
hash = 0;
}
return hash % getPartitions() == getPartitionNum();
}