我的代码中有2个命名流，希望使用fieldsgrouping将两个流中的元组发送到一个bolt。两条溪流的源头相同。所以，如果我的消息来源是 previousBolt 目标是 nextBolt 河流被命名为 stream1 以及 stream2 ，这就是我想要达到的目标-

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

我认为这应该有效，但在第二个字段分组的时候，我得到了一个nullpointerexception .fieldsGrouping(previousBolt,"stream2",new Fields(somefield)) 在构建拓扑时。请帮我找出我在这里遗漏了什么。谢谢！