关于 流合并（join）的问题

最近在做项目，有些业务复杂点的 用简单的 topology 感觉实现起来有点牵强。所以就研究研究trident，然后看到了流合并 merge和join我自己写个join例子，但是报了异常，网上搜也没有搜到。请教一下 群里的大神。
这个是程序：


这个是报的异常：

应该没有太大关系吧，楼使用graph相关的包或则类了吗

tntzbzc 发表于 2015-6-6 19:54
应该没有太大关系吧，楼使用graph相关的包或则类了吗

我没有使用这个包，它是在storm做join里面使用的

mjjian0 发表于 2015-6-6 21:35
我没有使用这个包，它是在storm做join里面使用的

代码本身没有错，可能是环境的原因

mituan2008 发表于 2015-6-7 01:57
代码本身没有错，可能是环境的原因

难道要在集群里面才行吗。我先试试。

请问，用trident时，做groupby的时候，数据多了就不执行了，日志也没报错，尝试修改配置文件中相关的buff、size相关的配置也不行。