Я использую storm для решения онлайн-проблем, но не могу понять, почему storm воспроизводит кортеж из spout . Повторная попытка с тем, что разбилось, может быть более эффективной, чем повтор от root, верно? Кто-нибудь может мне помочь? Спасибо

После реализации очень простой топологии apache storm в java я столкнулся с NPE, что вызвало некоторую путаницу. Это в основном мой основной метод: TologyBuilder builder = new TopologyBuilder(); builder.setSpout("spout", new CustomSpout(true),...

У меня возникла проблема с записью в файл с помощью log4j в storm. Перед отправкой моей топологии, то есть в моем основном методе, я написал несколько операторов журнала и настроил регистратор, используя:...

всем. Я хочу выполнить задание — один носик выдает числа в blotA, а BlotA выдает нечетные числа в Blot_odd , BlotA выдает четные числа в Blot_even. Я выбираю один из способов использования emit(streamId,tuple) , но не знаю, где определить свой...