由于怕系统太繁忙而导致消息处理不及时,所以storm设置了一个超时时间比较长
conf.setMessageTimeoutSecs(300);
当设置这个以后发现一个奇怪的现象,你使用kill命令停止topology,就会发现topology的状态一直是出于killed状态,不会退出(等待低于上面设置超时时间).
后面把这个去除,使用默认值以后,topology很快就退出了.
从现象上看
个人认为,停止以后,topology需要等待相应的消息超时时间才会退出,所以一直处于killed状态导致
不知道上面的推测是否正确,有没有哪位知道真正的原因?
谢谢!
|
|