1
Носик -> Bolt1 -> Bolt2 -> Bolt3 -> Ack orginalID (высвободит сообщение на очереди)Apache Сторм болт болт сообщения остановки или слоеное
Основная топология, кажется, работает в течение нескольких минут, но в некоторых что сообщение не получает ни отправлено, ни уничтожено, и болт никогда не вызывается. Я не могу сказать, как только поток java умирает, поскольку в журналах нет исключений или каких-либо признаков того, что что-то не так.
Apache storm .92 или .95 оба имеют одинаковые результаты для меня.
Я программирую шторм в течение нескольких лет и никогда не видел этого ....
Вы проверили все сообщения об ошибках топологии, работника, супервизора и nimbus? Поскольку вы упоминаете «ack» как последний шаг, я предполагаю, что вы допускаете отказоустойчивость. Каково ваше значение «max.spout.pending»? У вас есть узкое место в конвейере (используйте Storm UI, чтобы наблюдать, может ли весь болт поддерживать обработку входных кортежей)? –
@Don Вы уверены, что носик не заканчивается из кортежей, чтобы испустить? если один из ваших болтов падает с каким-то «неизвестным исключением», вы должны иметь возможность видеть, что кортежи терпят неудачу в носике таймаутом. –
@ MatthiasJ.Sax, ожидающий максимальный носик, не влияет на наблюдаемое поведение. Как только один кортеж полностью обработан, другой может быть испущен. –