Thanks a lot for your reply Adam.
On nimbus side, it looks like the stormjar never gets to the inbox; I checked
that the directory under stormdist was indeed crated:
2014-03-21 13:29:40 nimbus [INFO] Received topology submission for
test_topology with conf {"topology.max.task.parallelism" nil,
"topology.acker.executors" 1, "topology.kryo.register" nil,
"topology.kryo.decorators" (), "topology.name" "test_topology", "storm.id"
"test_topology-4-1395404980", "topology.debug" false}
2014-03-21 13:29:40 nimbus [WARN] Topology submission exception. (topology
name='test_topology') #<IllegalArgumentException
java.lang.IllegalArgumentException:
/test/storm//nimbus/inbox/stormjar-c75beeff-16fa-4175-8256-33ea2828fc68.jar to
copy to /test/storm//nimbus/stormdist/test_topology-4-1395404980 does not
exist!>
2014-03-21 13:29:40 TNonblockingServer [ERROR] Unexpected exception while
invoking!
java.lang.IllegalArgumentException:
/test/storm//nimbus/inbox/stormjar-c75beeff-16fa-4175-8256-33ea2828fc68.jar to
copy to /test/storm//nimbus/stormdist/test_topology-4-1395404980 does not exist!
at backtype.storm.daemon.nimbus$fn__3692.invoke(nimbus.clj:1133)
at clojure.lang.MultiFn.invoke(MultiFn.java:172)
at backtype.storm.daemon.nimbus$setup_storm_code.invoke(nimbus.clj:296)
at
backtype.storm.daemon.nimbus$fn__3592$exec_fn__1228__auto__$reify__3605.submitTopologyWithOpts(nimbus.clj:914)
at
backtype.storm.daemon.nimbus$fn__3592$exec_fn__1228__auto__$reify__3605.submitTopology(nimbus.clj:927)
at
backtype.storm.generated.Nimbus$Processor$submitTopology.getResult(Nimbus.java:1223)
at
backtype.storm.generated.Nimbus$Processor$submitTopology.getResult(Nimbus.java:1211)
at org.apache.thrift7.ProcessFunction.process(ProcessFunction.java:32)
at org.apache.thrift7.TBaseProcessor.process(TBaseProcessor.java:34)
at
org.apache.thrift7.server.TNonblockingServer$FrameBuffer.invoke(TNonblockingServer.java:632)
at
org.apache.thrift7.server.THsHaServer$Invocation.run(THsHaServer.java:201)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
at java.lang.Thread.run(Thread.java:722)
2014-03-21 13:29:44 nimbus [INFO] Cleaning up test_topology-4-1395404980
Thanks again for your help :)
Frantz
De : [email protected] [mailto:[email protected]] De la part de Adam Lewis
Envoyé : jeudi 20 mars 2014 22:00
À : user
Objet : Re: org.apache.thrift7.transport.TTransportException at deployment -
Looking for archives of issue
Are there any corresponding errors in the nimbus.log?
On Thu, Mar 20, 2014 at 11:33 AM, Mazoyer, Frantz
<[email protected]<mailto:[email protected]>> wrote:
Hello storm users,
I've recently run into the following issue upon deployment of a topology:
Internal error (system details org.apache.thrift7.transport.TTransportException)
Looking through the known issues, I found that an old issue was logged,
pointing to:
https://github.com/nathanmarz/storm/issues/92<https://www.google.com/url?q=https%3A%2F%2Fgithub.com%2Fnathanmarz%2Fstorm%2Fissues%2F92&sa=D&sntz=1&usg=AFQjCNEMujgWtNjoyqUKKE7NdhpTlH61Bw>
(ref : https://groups.google.com/forum/#!topic/storm-user/8zBVakyTnJY)
Which is a dead link.
Could you tell me where I can find a history of the old issues, or better yet
tell me what causes this problem ?
Thanks a lot for your help :)
Kind regards,
Frantz
Full stack trace:
Internal error (system details org.apache.thrift7.transport.TTransportException)
...
Caused by: 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.hp.cae.cep.engine.TopologyJobUnit.initialize(TopologyJobUnit.java:94)
at
com.hp.cae.dal.engine.AnalysisJobUnit.run(AnalysisJobUnit.java:187)
at
com.hp.cae.dal.engine.impl.AbstractJobUnitStarter.startJob(AbstractJobUnitStarter.java:183)
at
com.hp.cae.dal.engine.impl.CompositeJobUnitStarter.started(CompositeJobUnitStarter.java:198)
at
com.hp.cae.dal.engine.impl.AbstractStarter.start(AbstractStarter.java:394)
at
com.hp.cae.cep.engine.CepTopologyLauncher.launch(CepTopologyLauncher.java:226)
... 10 more
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)
... 17 more
