wangbing10gm
wangbing10gm
2017-03-14 10:05

storm提示connection attempt to Netty-Client-ubuntu1

  • storm

当我提交任务给storm时,发现2台supervisor中对应的日志输出都如下,请问如何解决:
connection attempt 367 to Netty-Client-ubuntu1:6704 failed: java.nio.channels.UnresolvedAddressException
b.s.m.n.StormClientHandler [INFO] Connection failed Netty-Client-ubuntu1:6704
java.nio.channels.UnresolvedAddressException
at sun.nio.ch.Net.checkAddress(Net.java:101) ~[?:1.8.0_121]
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:622) ~[?:1.8.0_121]
at org.apache.storm.shade.org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:108) [storm-core-0.10.2.jar:0.10.2]
at org.apache.storm.shade.org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:70) [storm-core-0.10.2.jar:0.10.2]
at org.apache.storm.shade.org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendDownstream(DefaultChannelPipeline.java:779) [storm-core-0.10.2.jar:0.10.2]
at org.apache.storm.shade.org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54) [storm-core-0.10.2.jar:0.10.2]
at org.apache.storm.shade.org.jboss.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:591) [storm-core-0.10.2.jar:0.10.2]
at org.apache.storm.shade.org.jboss.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:582) [storm-core-0.10.2.jar:0.10.2]
at org.apache.storm.shade.org.jboss.netty.channel.Channels.connect(Channels.java:634) [storm-core-0.10.2.jar:0.10.2]
at org.apache.storm.shade.org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207) [storm-core-0.10.2.jar:0.10.2]
at org.apache.storm.shade.org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229) [storm-core-0.10.2.jar:0.10.2]
at org.apache.storm.shade.org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182) [storm-core-0.10.2.jar:0.10.2]
at backtype.storm.messaging.netty.Client$Connect.run(Client.java:518) [storm-core-0.10.2.jar:0.10.2]
at org.apache.storm.shade.org.jboss.netty.util.HashedWheelTimer$HashedWheelTimeout.expire(HashedWheelTimer.java:546) [storm-core-0.10.2.jar:0.10.2]
at org.apache.storm.shade.org.jboss.netty.util.HashedWheelTimer$Worker.notifyExpiredTimeouts(HashedWheelTimer.java:446) [storm-core-0.10.2.jar:0.10.2]
at org.apache.storm.shade.org.jboss.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:395) [storm-core-0.10.2.jar:0.10.2]
at org.apache.storm.shade.org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) [storm-core-0.10.2.jar:0.10.2]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_121]

  • 点赞
  • 回答
  • 收藏
  • 复制链接分享

1条回答

为你推荐

换一换