2014-09-07 2 views

ответ

2

См. Приведенные ниже определения из базы кода.

nimbus.task.timeout.secs - see here

Как долго без heartbeating задачи может идти, прежде чем ореол будет рассмотрим задачу мертвых и передать его в другое место.

topology.message.timeout.secs - see here

Максимальное количество времени с учетом топологии, чтобы полностью обработать сообщений, испускаемых носиком. Если сообщение не отмечено в пределах этого временного интервала, Storm не выдает сообщение на носике. После этого некоторые потоки будут воспроизводить сообщение позже.

Посмотрите на presentation на внутренние штормы.