storm的bol分发问题
小弟现在想做的是从kafka的topic中获取数据,通过第一个bolt将数据存入hbase并将数据emit至第二个bolt,在第二个bolt中将数据处理后存放至redis。
问题是,一共传了5组数据,全部成功存入hbase,但是第二个bolt只执行了两次,也就是只有前两组数据存入了redis
环境:centos6.5 jstorm2.10 jedis
具体代码如下,求指教。
bolt1的excute:
1 |
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(4)
try { jedis.set(id, data); } finally{ pool.returnResource(jedis); } jedis实例用完后必须要返回给池中 修改后我的问题解决了 你要是有其他问题可以发出来探讨探讨
回复
哦,谢谢
楼主找到原因可以分享一下,同问
换个方向思考下,发现每次最多存8条数据到redis,后面的就存不进去,求问是jedis哪里配错了吗