Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2558#discussion_r168339726
--- Diff: storm-client/src/jvm/org/apache/storm/utils/TupleUtils.java ---
@@ -41,7 +41,7 @@ public static boolean isTick(Tuple tuple) {
}
public static <T> int chooseTaskIndex(List<T> keys, int numTasks) {
- return Math.abs(listHashCode(keys)) % numTasks;
+ return Math.abs(listHashCode(keys) % numTasks);
--- End diff --
Thanks. Never thought about this. Makes sense to me.
---
