请教个storm的问题,storm的spout可以设置并行度,如果设置为2,那么我就有两个执行器执行spout,如果我的spout是在消息队列里获取消息进行处理,那么这两个执行器的spout是否是并发?

0
请教个storm的问题,storm的spout可以设置并行度,如果设置为2,那么我就有两个执行器执行spout,如果我的spout是在消息队列里获取消息进行处理,那么这两个执行器的spout是否是并发?是不是每个执行器拿出一个消息扔到拓扑里的bolt去执行,而不用管这个消息之前的是否已处理完?请高手赐教,不胜感激
已邀请:
0

牟瑞 - 大数据 Hadoop 讲师 Hadoop入门课程地址:http://www.hellobi.com/course/39 有架构师,技术总监,CTO的职位请联系我! 2015-11-25 回答

用的是什么消息队列服务器?这个要看部署策略,并发读取也会有先后,一个spout拿到10个消息,另外一个spout拿另外10个消息。一般情况是拿到一个消息,扔到bolt里面去执行,消息处理是否完成,是否处理成功会写入不同的日志文件。

要回复问题请先登录注册