I am trying to run storm topology on a multi-node cluster. I have to machines,I am configured nimbus and 1 supervisor one Ist machine and 1 supervisor on the second machine.I am running zookeeper on the second machine.I am able to set it up and in storm ui both the supervisor entries are present but when I am trying to run the topology I am not able to read any data from the kafka-spout. While checking the logs this is what i found on both the machine.How to fix it ? I have followed these tutorial :
http://www.michael-noll.com/tutorials/running-multi-node-storm-cluster/ http://www.allprogrammingtutorials.com/tutorials/setting-up-apache-storm-cluster.php 2015-08-20T10:41:07.982+0530 b.s.m.n.Client [INFO] creating Netty Client, connecting to ritesh-VirtualBox:6710, bufferSize: 5242880 2015-08-20T10:41:07.980+0530 b.s.m.n.Client [INFO] connection established to Netty-Client-Ritesh-RM/127.0.1.1:6716 2015-08-20T10:41:07.980+0530 b.s.m.n.StormClientErrorHandler [INFO] Connection failed Netty-Client-ritesh-VirtualBox:6704 java.nio.channels.UnresolvedAddressException: null at sun.nio.ch.Net.checkAddress(Net.java:127) ~[na:1.7.0_79] at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:645) ~[na:1.7.0_79] at org.apache.storm.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:108) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:70) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendDownstream(DefaultChannelPipeline.java:779) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:591) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:582) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.channel.Channels.connect(Channels.java:634) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.channel.AbstractChannel.connect(AbstractChannel.java:207) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182) [storm-core-0.9.4.jar:0.9.4] at backtype.storm.messaging.netty.Client$Connector.call(Client.java:612) [storm-core-0.9.4.jar:0.9.4] at backtype.storm.messaging.netty.Client$Connector.call(Client.java:595) [storm-core-0.9.4.jar:0.9.4] at java.util.concurrent.FutureTask.run(FutureTask.java:262) [na:1.7.0_79] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) [na:1.7.0_79] at java.util.concurrent.FutureTask.run(FutureTask.java:262) [na:1.7.0_79] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178) [na:1.7.0_79] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292) [na:1.7.0_79] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) [na:1.7.0_79] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [na:1.7.0_79] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_79] 2015-08-20T10:41:07.979+0530 b.s.m.n.StormClientErrorHandler [INFO] Connection failed Netty-Client-ritesh-VirtualBox:6706 java.nio.channels.UnresolvedAddressException: null at sun.nio.ch.Net.checkAddress(Net.java:127) ~[na:1.7.0_79] at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:645) ~[na:1.7.0_79] at org.apache.storm.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:108) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:70) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendDownstream(DefaultChannelPipeline.java:779) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:591) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:582) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.channel.Channels.connect(Channels.java:634) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.channel.AbstractChannel.connect(AbstractChannel.java:207) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229) [storm-core-0.9.4.jar:0.9.4] at org.apache.storm.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182) [storm-core-0.9.4.jar:0.9.4] at backtype.storm.messaging.netty.Client$Connector.call(Client.java:612) [storm-core-0.9.4.jar:0.9.4] at backtype.storm.messaging.netty.Client$Connector.call(Client.java:595) [storm-core-0.9.4.jar:0.9.4] at java.util.concurrent.FutureTask.run(FutureTask.java:262) [na:1.7.0_79] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) [na:1.7.0_79] at java.util.concurrent.FutureTask.run(FutureTask.java:262) [na:1.7.0_79] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178) [na:1.7.0_79] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292) [na:1.7.0_79] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) [na:1.7.0_79] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [na:1.7.0_79] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_79]
