qcbb001 发表于 2016-6-27 17:16
怎么配置？可以先参考Storm源代码中的Config.java.
其实这应该是storm的优化，除了max_spout_pending， ...

好的，我试试看。
谢谢你~

一个好人 发表于 2016-6-27 15:05
我看到网上说的topology.max.spout.pending自己不设置的话默认为1，那我这个值应该设置成多大呢？应该有 ...

怎么配置？可以先参考Storm源代码中的Config.java.
其实这应该是storm的优化，除了max_spout_pending，其它的也可以优化下。
下面是建议配置
内存
worker.childopts: "-Xmx2048m"
max_spout_pending=100000    //spout可以缓存的tuple数目
topology_message_timeout_secs=60      // message被完全处理完的时间，超过这个时间，spout 将产生failed

qcbb001 发表于 2016-6-27 15:01
这个倒是可能的原因之一
topology.max.spout.pending，楼主如果没有设置的话，最好设置下

我看到网上说的topology.max.spout.pending自己不设置的话默认为1，那我这个值应该设置成多大呢？应该有个参考吧~
谢谢~

一个好人 发表于 2016-6-27 13:03
1、时间固定与否我没统计过，不过该storm程序一般运行了几个小时以上才会出现spout failed的情况。  2、 ...

这个倒是可能的原因之一
topology.max.spout.pending，楼主如果没有设置的话，最好设置下

时间是固定的吗？内存使用如何