Github user Ethanlm commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2551#discussion_r167247297
  
    --- Diff: 
storm-client/src/jvm/org/apache/storm/grouping/LoadAwareShuffleGrouping.java ---
    @@ -85,6 +85,7 @@ public void prepare(WorkerTopologyContext context, 
GlobalStreamId stream, List<I
             sourceNodeInfo = new NodeInfo(context.getThisWorkerHost(), 
Sets.newHashSet((long) context.getThisWorkerPort()));
             taskToNodePort = context.getTaskToNodePort();
             this.targetTasks = targetTasks;
    +        capacity = targetTasks.size() == 1 ? 1 : Math.max(1000, 
targetTasks.size() * 5);
    --- End diff --
    
    I just added the tests in the last commit. Is that what you were saying? 
Sorry if I misunderstood it


---

Reply via email to