您可以通过配置参数设置超时 Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS 。看到 https://storm.apache.org/javadoc/apidocs/backtype/storm/Config.html#TOPOLOGY_MESSAGE_TIMEOUT_SECS
Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS
默认值为30秒,请参阅 defaults.yaml 这里: https://github.com/apache/storm/blob/master/conf/defaults.yaml
defaults.yaml
# maximum amount of time a message has to complete before it's considered failed topology.message.timeout.secs: 30
当一个元组失败时,它应该出现在Storm UI中并且也应该被记录(也许你需要调整日志级别)。所以你可以仔细检查元组是否超时。