在storm的代码中,可以使用以下方法解决该问题:
-
检查代码,确保spout的输出流与bolt的输入流匹配。
-
确认您的拓扑图中spout和bolt的配置和设置都正确。
-
确认spout的nextTuple()方法是否被正确地实现。
以下是一些示例代码,这些代码可以在Spout的nextTuple()方法中使用,以确保在所有执行器中均发出元组:
//方法一:
@Override
public void nextTuple() {
List
这些方法可以在Spout的nextTuple()方法中使用,以确保在所有执行器中均发出元组。