Reputation: 445
I am trying to submit the ExclamationTopology example found in storm-start to a single node cluster and getting the following error
Exception in thread "main" java.lang.RuntimeException: org.apache.storm.thrift.TApplicationException: Internal error processing beginFileUpload
at org.apache.storm.StormSubmitter.submitJarAs(StormSubmitter.java:507)
at org.apache.storm.StormSubmitter.submitTopologyInDistributeMode(StormSubmitter.java:332)
at org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:274)
at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:206)
at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:169)
at ExclamationTopology.main(ExclamationTopology.java:85)
Caused by: org.apache.storm.thrift.TApplicationException: Internal error processing beginFileUpload
at org.apache.storm.thrift.TServiceClient.receiveBase(TServiceClient.java:79)
at org.apache.storm.generated.Nimbus$Client.recv_beginFileUpload(Nimbus.java:1035)
at org.apache.storm.generated.Nimbus$Client.beginFileUpload(Nimbus.java:1023)
at org.apache.storm.StormSubmitter.submitJarAs(StormSubmitter.java:476)
My environment:
Upvotes: 1
Views: 1836
Reputation: 21
Do you have nimbus logs for your case?
Sometimes there is useful information on this kind of error messages. Look for
No available slots for topology:
In my case I had to remove corrupt topologies with a storm admin command called
storm admin remove_corrupt_topologies
Maybe this helps in your case!
Upvotes: 2