Skip to content

Instantly share code, notes, and snippets.

View fmw's full-sized avatar

Filip de Waard fmw

View GitHub Profile
The relevant lines in nimbus.log:
2013-06-28 09:46:36 nimbus [INFO] Uploading file from client to /mnt/storm/nimbus/inbox/stormjar-95cc3086-2537-4a8d-bd52-4bfc2cefdac2.jar
2013-06-28 10:18:05 nimbus [INFO] Finished uploading file from client: /mnt/storm/nimbus/inbox/stormjar-95cc3086-2537-4a8d-bd52-4bfc2cefdac2.jar
The error:
Running: java -client -Dstorm.options= -Dstorm.home=/home/fmw/bin/storm-0.8.2 -Djava.library.path=/usr/local/lib:/opt/local/lib:/usr/lib -Dstorm.conf.file= -cp /home/fmw/bin/storm-0.8.2/storm-0.8.2.jar:/home/fmw/bin/storm-0.8.2/lib/commons-codec-1.4.jar:/home/fmw/bin/storm-0.8.2/lib/tools.logging-0.2.3.jar:/home/fmw/bin/storm-0.8.2/lib/minlog-1.2.jar:/home/fmw/bin/storm-0.8.2/lib/junit-3.8.1.jar:/home/fmw/bin/storm-0.8.2/lib/reflectasm-1.07-shaded.jar:/home/fmw/bin/storm-0.8.2/lib/curator-client-1.0.1.jar:/home/fmw/bin/storm-0.8.2/lib/kryo-2.17.jar:/home/fmw/bin/storm-0.8.2/lib/ring-jetty-adapter-0.3.11.jar:/home/fmw/bin/storm-0.8.2/lib/commons-logging-1.1.1.jar:/home/fmw/bin/storm-0.
(defn make-topology
[{:keys [seed-uris
max-depth
follow-links?-scoring-fn
follow-individual-link?-scoring-fn
store?-scoring-fn
content-processing-fn]}]
(doseq [uri seed-uris]
(queue/add-uri! (util/md5 (util/get-host uri)) uri 0))