Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2366#discussion_r143865842
--- Diff:
storm-client/src/jvm/org/apache/storm/grouping/LoadAwareShuffleGrouping.java ---
@@ -50,10 +69,28 @@
volatile int[] choices;
private volatile int[] prepareChoices;
private AtomicInteger current;
+ private Scope currentScope;
+ private NodeInfo sourceNodeInfo;
+ private List<Integer> targetTasks;
+ private AtomicReference<Map<Integer, NodeInfo>> taskToNodePort;
+ private Map<String, Object> conf;
+ private DNSToSwitchMapping dnsToSwitchMapping;
+ private Map<Scope, List<Integer>> localityGroup;
+ private double HIGHER_BOUND;
--- End diff --
Thanks. Fixed it
---
