Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2551#discussion_r166758132
--- 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 : targetTasks.size() *
MAX_WEIGHT;
--- End diff --
OK we are ensuring it already.
---
