Hi All ,

 I recently upgraded my storm component from 0.9.0 to 0.9.4 ,everything is
up and running (As i am able to see the nimbus and supervisors are up and
running in storm UI) .But when i submit the topology i am getting the
following exception :

   I am trying to run the Storm-Starter-0.9.4  topology in my cluster
having 2 supervisor nodes .

Also find the screenshot of my storm UI .

Kindly help me to fix this issue .
.
Exception in thread "main" java.lang.RuntimeException:
org.apache.thrift7.transport.TTransportException
        at backtype.storm.StormSubmitter.submitJar(StormSubmitter.java:282)
        at backtype.storm.StormSubmitter.submitJar(StormSubmitter.java:223)
        at
backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:120)
        at
backtype.storm.StormSubmitter.submitTopologyWithProgressBar(StormSubmitter.java:176)
        at
backtype.storm.StormSubmitter.submitTopologyWithProgressBar(StormSubmitter.java:158)
        at storm.starter.WordCountTopology.main(WordCountTopology.java:94)
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_beginFileUpload(Nimbus.java:337)
        at
backtype.storm.generated.Nimbus$Client.beginFileUpload(Nimbus.java:325)
        at backtype.storm.StormSubmitter.submitJar(StormSubmitter.java:253)
        ... 5 more

Reply via email to