问一下：storm中，当bolt或spout任务即将宕掉的时候，怎么做一些清理动作？

问一下：storm中，当bolt或spout任务即将宕掉的时候，做一些清理动作？

用 cleanup（），或则close（）

试过，没有生效

close方法在该spout关闭前执行，但是并不能得到保证其一定被执行。spout是作为task运行在worker内，在cluster模式下，supervisor会直接kill -9 woker的进程，这样它就无法执行了。
cleanup也一样，如果进程直接挂掉了，是不执行的
所以说storm要做好监控