Группировка полей из нескольких потоков в болте в Apache Storm - PullRequest
Новая
       48

Группировка полей из нескольких потоков в болте в Apache Storm

0 голосов
/ 23 октября 2019

В моем коде 2 именованных потока, и я хочу отправить кортежи из обоих потоков болту с использованием fieldsGrouping. Источник обоих потоков один и тот же болт. Итак, если мой исходный болт равен previousBolt, а целевой болт равен nextBolt, а потоки названы stream1 и stream2, это то, чего я хочу достичь - 

topologybuilder.setbolt(nextBolt, IRichBolt, parallelism_hint)
.fieldsGrouping(previousBolt,"stream1",new Fields(somefield))
.fieldsGrouping(previousBolt,"stream2",new Fields(somefield))

Я думал, что этодолжен был сработать, но я получаю исключение NullPointerException в точке второго поля fieldsGrouping .fieldsGrouping(previousBolt,"stream2",new Fields(somefield)), когда строится топология. Пожалуйста, помогите мне определить, что мне здесь не хватает. Спасибо!

...