storm并发度引发的问题

查看数: 19948 | 评论数: 3 | 收藏 0

关灯 | 提示：支持键盘翻页<-左右->

发布时间: 2015-4-25 17:33

本帖最后由 mjjian0 于 2015-4-25 18:16 编辑我在对一些数据做统计，用到redies，把统计结果放在redies中，然后下一个tuple来了从redies中取出来然后在做统计，统计后在放到redies中供程序对后面的tuple做统计处 ...

starrycheng 发表于 2015-4-26 01:13:00

parallelism_hint是什么？
感觉这个直接使用storm机制就可以。

例如下图，那种bolt连续bolt的形式。

第一个bolt读取redies做统计，统计后在放到redies中，然后第二个bolt接着处理
他们之间本身存在顺序，所以不需要什么锁。

yepiaochen 发表于 2015-4-25 21:06:42

使用curator加锁

muyannian 发表于 2015-4-25 18:50:04

可以的试试锁

图文精华