storm问题求助!

我在本地运行
我这样设置在分布式上就出不来结果
builder.setBolt("split", new SplitSentence(), 2).shuffleGrouping("clicklogspout");
我这样设置结果就出来了
builder.setBolt("split", new SplitSentence(), 8).shuffleGrouping("clicklogspout");

而且结果还少了很多,好像只有spout和bolt在同一worker中才出结果
这是咋回事

阅读 2.5k
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进