[ 
https://issues.apache.org/jira/browse/STORM-1038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15090129#comment-15090129
 ] 

ASF GitHub Bot commented on STORM-1038:
---------------------------------------

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

    https://github.com/apache/storm/pull/728#discussion_r49248827
  
    --- Diff: storm-core/src/jvm/backtype/storm/messaging/netty/Client.java ---
    @@ -17,41 +17,31 @@
      */
     package backtype.storm.messaging.netty;
     
    -import java.net.InetSocketAddress;
    -import java.net.SocketAddress;
    -import java.util.Iterator;
    -import java.util.Collection;
    -import java.util.Map;
    -import java.util.HashMap;
    -import java.util.concurrent.atomic.AtomicBoolean;
    -import java.util.concurrent.atomic.AtomicInteger;
    -import java.util.concurrent.atomic.AtomicReference;
    -import java.lang.InterruptedException;
    -
     import backtype.storm.Config;
     import backtype.storm.grouping.Load;
     import backtype.storm.messaging.ConnectionWithStatus;
    -import backtype.storm.messaging.TaskMessage;
     import backtype.storm.messaging.IConnectionCallback;
    +import backtype.storm.messaging.TaskMessage;
     import backtype.storm.metric.api.IStatefulObject;
     import backtype.storm.utils.StormBoundedExponentialBackoffRetry;
     import backtype.storm.utils.Utils;
    -import org.jboss.netty.bootstrap.ClientBootstrap;
    -import org.jboss.netty.channel.Channel;
    -import org.jboss.netty.channel.ChannelFactory;
    -import org.jboss.netty.channel.ChannelFuture;
    -import org.jboss.netty.channel.ChannelFutureListener;
    -import org.jboss.netty.util.HashedWheelTimer;
    -import org.jboss.netty.util.Timeout;
    -import org.jboss.netty.util.TimerTask;
    +import io.netty.bootstrap.Bootstrap;
    +import io.netty.channel.*;
    +import io.netty.channel.socket.nio.NioSocketChannel;
    +import io.netty.util.HashedWheelTimer;
    +import io.netty.util.Timeout;
    +import io.netty.util.TimerTask;
     import org.slf4j.Logger;
     import org.slf4j.LoggerFactory;
     
    -
    -import java.util.ArrayList;
    -import java.util.List;
    +import java.net.InetSocketAddress;
    +import java.net.SocketAddress;
    +import java.util.*;
    --- End diff --
    
    please remove wildcard and import the packages you needed


> Upgrade netty transport from 3.x to 4.x
> ---------------------------------------
>
>                 Key: STORM-1038
>                 URL: https://issues.apache.org/jira/browse/STORM-1038
>             Project: Apache Storm
>          Issue Type: Dependency upgrade
>          Components: storm-core
>            Reporter: Hang Sun
>            Priority: Minor
>              Labels: performance
>   Original Estimate: 168h
>  Remaining Estimate: 168h
>
> It will be nice to upgrade netty to 4.x to take advantage of its more 
> efficient memory usage.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to