[GitHub] storm pull request #2366: [STORM-2686] Add locality awareness to LoadAwareSh...

[Ethanlm]

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


---