I have submitted simple storm topology on a local cluster mode
using LocalCluster on windows env for development/testing purposes.
I created kafka spout and tested my topology by sending(via separate
process) messages.
I am trying to send 10,000 messages with delay of one sec between each.
for ~7000 messages everything worked as expected(received and processed by
the topology) but after a few more the app is crushing unexpectedly and I
find that error on console:
14:40:28,925 INFO supervisor:0 - Downloading code for storm id
push-message-topology-1-1419336027 from
C:\Users\EXT_ID~1\AppData\Local\Temp\282695d8-eee9-4cb4-ae7a-7aae70eeec68\nimbus\stormdist\push-message-topology-1-1419336027
14:40:28,927 ERROR event:0 - Error when processing event
java.io.FileNotFoundException: Source
'C:\Users\EXT_ID~1\AppData\Local\Temp\282695d8-eee9-4cb4-ae7a-7aae70eeec68\nimbus\stormdist\push-message-topology-1-1419336027'
does not exist
at org.apache.commons.io.FileUtils.copyDirectory(FileUtils.java:1368)
at org.apache.commons.io.FileUtils.copyDirectory(FileUtils.java:1261)
at org.apache.commons.io.FileUtils.copyDirectory(FileUtils.java:1230)
at backtype.storm.daemon.supervisor$fn__5021.invoke(supervisor.clj:512)
at clojure.lang.MultiFn.invoke(MultiFn.java:236)
at
backtype.storm.daemon.supervisor$mk_synchronize_supervisor$this__4917.invoke(supervisor.clj:325)
at backtype.storm.event$event_manager$fn__2379.invoke(event.clj:39)
at clojure.lang.AFn.run(AFn.java:24)
at java.lang.Thread.run(Thread.java:745)
14:40:28,932 INFO util:0 - Halting process: ("Error when processing an
event")
Process finished with exit code 20
Any idea what's the cause?
thank you.
