doesn't always work in local mode because the cluster gets shut down and
can't clean things up.
On Thu, Dec 6, 2012 at 4:04 AM, 友道 周 wrote:
hi all:
I writted bolt/spout with python and used shellbolt/shellspout.
when testing with LocalCluster, topology died
when java.lang.runtimeexception was thrown by some bolt/spout, but some
processes of topology such as splitsentence.py was still running.
How to shutdown all subprocesses(multilang processes) when topology
dies even if some bolt/spout throws exception?
hi all:
I writted bolt/spout with python and used shellbolt/shellspout.
when testing with LocalCluster, topology died
when java.lang.runtimeexception was thrown by some bolt/spout, but some
processes of topology such as splitsentence.py was still running.
How to shutdown all subprocesses(multilang processes) when topology
dies even if some bolt/spout throws exception?
--
Twitter: @nathanmarz
http://nathanmarz.com
