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.


---

Reply via email to