2015-05-29 3 views
1

Как часть разработки streamparse, у нас есть BatchingBolt, который обрабатывает кортежи пакетами. Он предназначен для использования с вещами, такими как базы данных, которые более эффективны, когда вы отправляете вещи партиями.Сохраняет ли Storm кеширование на болты при дезактивации топологии?

Недавно я предложил переключить реализацию BatchingBolt с использованием подхода таймера/потока к использованию тик-привязок; однако, один из моих коллег-разработчиков указал, что с нашим текущим подходом окончательная партия, безусловно, будет обработана, когда топология отключится (и она находится в неактивном состоянии), тогда как это явно не документировано нигде о тиковых наборах.

Таким образом, мой вопрос заключается в следующем: разве шторм продолжает отправлять тик-кортежи на болты после того, как был убит/деактивирован, пока он находится в ожидании/неактивном периоде? topology lifecycle docs не уточняют.

ответ

0

http://mail-archives.apache.org/mod_mbox/storm-user/201506.mbox/%[email protected].com%3E

AFAIK, "установка-тик!" вызывается с момента запуска исполнителя (который планирует таймер тика для каждого исполнителя), а тик-кортежи будут выпущены, если только работник не остановится.

Короче говоря, ваш коллега прав.

+1

Добро пожаловать в переполнение стека! Вы можете немного разработать свой ответ и/или включить ссылку на дискуссию группы пользователей Storm, о которой вы указали, и/или любую ссылку, чтобы ваш ответ можно считать каноническим и лучшего качества. Приветствия. – KeatsPeeks

Смежные вопросы