If I explicitly throw an exception in the storm-starter clojure example, as
shown in the diff below, it shows up nicely when I run in local mode with
coventry@samjoko:~/storm-starter$ lein run -m
storm.starter.clj.word-count
However, when I run it on a storm cluster with a command like
coventry@samjoko:~/storm-starter$
~/storm-starter/target/storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar
storm.starter.clj.word_count count
I am not sure where these errors are being reported. Are they logged
anywhere, and if not, can I get them to be?
Best regards,
Alex
index ce2725d..c82fd0f 100644
--- a/src/clj/storm/starter/clj/word_count.clj
+++ b/src/clj/storm/starter/clj/word_count.clj
@@ -11,6 +11,7 @@
"an apple a day keeps the doctor away"]]
(spout
(nextTuple []
+ (throw (Exception. "Where does this show up?"))
(Thread/sleep 100)
(emit-spout! collector [(rand-nth sentences)])
)