[GitHub] storm pull request #2704: STORM-1038: Upgrade to Netty 4

[danny0405]

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

    https://github.com/apache/storm/pull/2704#discussion_r193437371
  
    --- Diff: storm-client/src/jvm/org/apache/storm/utils/TransferDrainer.java 
---
    @@ -40,94 +41,39 @@ public void add(TaskMessage taskMsg) {
         }
     
         public void send(Map<Integer, NodeInfo> taskToNode, Map<NodeInfo, 
IConnection> connections) {
    -        HashMap<NodeInfo, ArrayList<ArrayList<TaskMessage>>> 
bundleMapByDestination = groupBundleByDestination(taskToNode);
    -
    -        for (Map.Entry<NodeInfo, ArrayList<ArrayList<TaskMessage>>> entry 
: bundleMapByDestination.entrySet()) {
    +        HashMap<NodeInfo, Stream<TaskMessage>> bundleMapByDestination = 
groupBundleByDestination(taskToNode);
    +        
    +        for (Map.Entry<NodeInfo, Stream<TaskMessage>> entry : 
bundleMapByDestination.entrySet()) {
    --- End diff --
    
    nit: whitespace


---