You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Akshay Bogawat <ak...@gmail.com> on 2014/01/30 06:24:21 UTC

Intermittent "TransportException" while submitting storm topology

Hi,
We are getting the following error while submitting storm topology, but the
error is not consistent. Once supervisor nodes are started, we are able to
submit few topology. But after couple of hours, if we try to submit
topology, then we get the following exception. After restarting supervisor
nodes it works fine again.

59270417 [Thread-17] ERROR org.apache.zookeeper.server.NIOServerCnxn  -
Thread Thread[Thread-17,5,main] died
java.lang.RuntimeException: org.apache.thrift7.transport.TTransportException
        at
backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:94)
        at
backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:40)
        at
com.vbi.storm.service.StormServiceImpl$2.run(StormServiceImpl.java:496)
Caused by: org.apache.thrift7.transport.TTransportException
        at
org.apache.thrift7.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
        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_submitTopology(Nimbus.java:145)
        at
backtype.storm.generated.Nimbus$Client.submitTopology(Nimbus.java:129)
        at
backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:80)
        ... 2 more