报错信息如下:
[INFO 2017-03-31 20:27:01 b.s.m.TransportFactory:61 main] TransportFactory makeContext done...
[INFO 2017-03-31 20:27:01 c.a.j.d.w.WorkerData:307 main] Disruptor use sleep:true, limited size:true
[INFO 2017-03-31 20:27:01 c.a.j.d.w.WorkerData:347 main] Current worker taskList:[8, 2, 10, 4, 6]
[INFO 2017-03-31 20:27:01 c.a.j.d.w.WorkerData:702 main] Updated tasksToComponentMap:{1=__topology_master, 2=__acker, 3=lessSixHundredBolt, 4=lessSixHundredBolt, 5=lessTenHundredBolt, 6=lessTenHundredBolt, 7=myFilterBolt1, 8=myFilterBolt1, 9=collect, 10=randomSpout}
[INFO 2017-03-31 20:27:02 c.a.j.d.w.WorkerData:378 main] Successfully create WorkerData
[ERROR 2017-03-31 20:27:02 c.a.j.m.n.NettyContext:95 main] Failed to instance NettyServer
java.net.BindException: 地址已在使用
at sun.nio.ch.Net.listen(Native Method) ~[na:1.8.0_92]
at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:224) ~[na:1.8.0_92]
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74) ~[na:1.8.0_92]
at org.jboss.netty.channel.socket.nio.NioServerBoss$RegisterTask.run(NioServerBoss.java:193) ~[netty-3.9.0.Final.jar:na]
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.processTaskQueue(AbstractNioSelector.java:372) ~[netty-3.9.0.Final.jar:na]
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:296) ~[netty-3.9.0.Final.jar:na]
at org.jboss.netty.channel.socket.nio.NioServerBoss.run(NioServerBoss.java:42) ~[netty-3.9.0.Final.jar:na]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) ~[na:1.8.0_92]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) ~[na:1.8.0_92]
at java.lang.Thread.run(Thread.java:745) ~[na:1.8.0_92]
[INFO 2017-03-31 20:27:02 c.a.j.u.JStormUtils:181 main] Halting process: Failed to bind 6900
解决方法:
通过如下命令查看端口占用情况,因为以上错误报占用了6900端口,执行命令
显示是haproxy占用了相关端口
lsof -i |grep 6900
Paste_Image.png
这个端口是jstorm通过netty在多个进行之间进行通信
修改jstorm supervisor端口
如下,修改以后即可
Paste_Image.png
网友评论