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?