Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2366#discussion_r143837500
--- Diff:
storm-client/src/jvm/org/apache/storm/grouping/LoadAwareShuffleGrouping.java ---
@@ -50,10 +61,28 @@
volatile int[] choices;
private volatile int[] prepareChoices;
private AtomicInteger current;
+ private AtomicReference<Scope> currentScopeRef;
--- End diff --
I think you are right---
