Время ожидания кортежа Apache Storm истекло через 10 минут, но параметр topology.message.timeout.secs настроен как 5 минут

У нас есть топология с topology.message.timeout.secs = 300 секунд. Недавно мы столкнулись с проблемой, когда первый болт после носика достигал емкости ~2. Болт начал обрабатывать кортежи очень медленно (он начал обрабатывать кортежи через 5 минут после того, как носик их выдал). Через несколько минут носик выдал кортежи, но до того, как болт смог начать обработку, истекло время ожидания кортежа.

Странная часть заключается в том, что разница во времени между отказом кортежа и его отправкой составляет 10 минут.

Ожидалось, что кортеж должен выйти из строя через 5 минут (настроено 300 секунд).

Любые мысли / информация о том, почему настроенный тайм-аут не был действительно рассмотрен, были бы очень полезны. Есть ли какая-либо другая конфигурация, которая может повлиять на тайм-аут кортежа?

0 ответов