用户工具


1、kill命令
bin/storm  kill  myTestTpyo -w 20

2、kill过程
2.1 先停止执行spout的nextTuple函数

2.2 等待20秒让下游的bolt处理完数据,并ack掉。保证下次启动时数据能完美衔接。
如果不等待直接kill的话,有些处理完的tuple没来的及ack。那么下次重启后就会有一部分数据被消费2次