什么是nimbus.task.timeout.secs属性是风暴

Question

什么是nimbus.task.timeout.secs属性是风暴。它与topology.message.timeout.secs的不同之处在于。

Answer 1

请参阅下面代码库中的定义。

nimbus.task.timeout.secs - 请看这里

在没有心跳的情况下，任务可以持续多久，然后nimbus就会考虑任务死亡，并将其重新分配到另一个位置。

topology.message.timeout.secs - 请看这里

拓扑的最大时间，用于完全处理由喷口发出的消息。如果消息在此时间范围内未被加标，Storm将导致突发事件上的消息失败。一些喷口实现将在稍后时间重放该消息。

看看风暴内部的介绍性。