storm的bol分发问题

发布于 2021-11-28 15:29:50 字数 347 浏览 915 评论 4

小弟现在想做的是从kafka的topic中获取数据,通过第一个bolt将数据存入hbase并将数据emit至第二个bolt,在第二个bolt中将数据处理后存放至redis。

问题是,一共传了5组数据,全部成功存入hbase,但是第二个bolt只执行了两次,也就是只有前两组数据存入了redis

环境:centos6.5 jstorm2.10 jedis

具体代码如下,求指教。

bolt1的excute:

1

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(4

后知后觉 2021-12-03 22:44:54

try { jedis.set(id, data); } finally{ pool.returnResource(jedis); } jedis实例用完后必须要返回给池中 修改后我的问题解决了 你要是有其他问题可以发出来探讨探讨

秋意浓 2021-12-03 20:48:36

回复
哦,谢谢

甜柠檬 2021-12-03 16:05:27

楼主找到原因可以分享一下,同问

泪冰清 2021-11-30 18:06:53

换个方向思考下,发现每次最多存8条数据到redis,后面的就存不进去,求问是jedis哪里配错了吗

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文