分类： 高性能计算
2014-08-11 10:17:21
baobingzhe2016-02-18 10:47:26
有个问题想请教下，具体的场景是，一个任务，两台服务器上跑两个worker，正常情况下，推送十条消息，处理正常。手动kill掉worker1的进程，这个时候storm本身会把worker拉起，这个时候我再次推送十条消息，两个worker上均有部分消息成功，部分消息出现：所以的bolt处理完成，阻塞在collector.ack中，一段时间后调用fail结束。现在用的分组方式是localorshuffle，改为shuffle之后会有改善，想问下这个阻塞的原因到底是什么？
