Hello! How many bolts do you have in the topology? I'm getting the same error when I have more than 20 bolts in the topology. My cluster configuration is: 1 ZK, 4 Woker Machines. Is there any limitation regarding the number of bolts in the topology or is due the fact that I have 1 ZK in the topology? Thanks. Florin
On Tue, Aug 12, 2014 at 10:04 AM, Chandrahas Gurram <[email protected]> wrote: > Hello, > whenever I try to deploy my jar onto nimbus I am getting the following > exception > I am able to login into nimbus and also the port i am using is open. > please help me with this issue. > > 1198 [main] INFO backtype.storm.StormSubmitter - Jar not uploaded to > master yet. Submitting jar... > 1704 [main] INFO backtype.storm.StormSubmitter - Uploading topology jar > storm-sample-0.0.1-SNAPSHOT-jar-with-dependencies.jar to assigned location: > /mnt/storm/nimbus/inbox/stormjar-b2fc636e-fc02-4cda-ab6a-bf06f73dd7c3.jar > Exception in thread "main" java.lang.RuntimeException: > org.apache.thrift7.transport.TTransportException: java.net.SocketException: > Connection reset > at backtype.storm.StormSubmitter.submitJar(StormSubmitter.java:266) > at backtype.storm.StormSubmitter.submitJar(StormSubmitter.java:207) > at > backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:104) > at backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:70) > at com.peel.kinesisStorm.SampleTopology.main(SampleTopology.java:91) > Caused by: org.apache.thrift7.transport.TTransportException: > java.net.SocketException: Connection reset > at > org.apache.thrift7.transport.TIOStreamTransport.read(TIOStreamTransport.java:129) > at org.apache.thrift7.transport.TTransport.readAll(TTransport.java:84) > at > org.apache.thrift7.transport.TFramedTransport.readFrame(TFramedTransport.java:129) > at > org.apache.thrift7.transport.TFramedTransport.read(TFramedTransport.java:101) > at org.apache.thrift7.transport.TTransport.readAll(TTransport.java:84) > at > org.apache.thrift7.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378) > at > org.apache.thrift7.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297) > at > org.apache.thrift7.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204) > at > org.apache.thrift7.TServiceClient.receiveBase(TServiceClient.java:69) > at > backtype.storm.generated.Nimbus$Client.recv_uploadChunk(Nimbus.java:361) > at backtype.storm.generated.Nimbus$Client.uploadChunk(Nimbus.java:347) > at backtype.storm.StormSubmitter.submitJar(StormSubmitter.java:255) > ... 4 more > Caused by: java.net.SocketException: Connection reset > at java.net.SocketInputStream.read(SocketInputStream.java:196) > at java.net.SocketInputStream.read(SocketInputStream.java:122) > at > org.apache.thrift7.transport.TIOStreamTransport.read(TIOStreamTransport.java:127) > ... 15 more > > > ThankYou, > G V Chandrahas Raj >
