Hi,
   Can someone explain the internals behind "NPE from deep inside
storm<https://github.com/nathanmarz/storm/wiki/Troubleshooting#nullpointerexception-from-deep-inside-storm>"
as stated in troubleshooting document? (like is there a use of thread
locals, etc)
   Does it imply (which of the following)?:
      (1) only storm's executor thread should use the output collector
      (2) output collector should be invoked from one thread throughout its
lifetime - either from storm's executor thread or any thread that that
topology spawns
      (3) any number of threads can use it as long as the access is
synchronized (maybe like synchronized(outputCollector) {...})

   The code is in clojure and hence I'm not able to follow what could
enforce such a restriction.

Thanks,
Srinath.

Reply via email to