Hello! Check into the nimbus log file a text that o.a.t.s.TNonblockingServer [ERROR] Read a frame size of , which is bigger than the maximum allowable buffer size for ALL connections. If you find this text your topology has more than the default 1MB size allowed to be passed with the thrift protocol. Solution: in the storm.yaml on the nimbus node increase the parameter "nimbus.thrift.max_buffer_size" (it is specified in bytes). in order to fit your topology needs. According to this post http://qnalist.com/questions/4768442/nimbus-fails-after-uploading-topology-reading-too-large-of-frame-size (look at the bottom of the page the Adam's response) set up a larger size. I hope that these help. Good luck. Florin
On Fri, Aug 15, 2014 at 6:52 PM, Spico Florin <[email protected]> wrote: > 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 >> > >
