采纳答案成功!
向帮助你的同学说点啥吧!感谢那些助人为乐的人
一个task就是一个线程,要想提高效率启动多个task就好了,为什么还要给task分组也就是executor
灰色部分就是executor, 为什么要给task分个组呢?有什么用途,还是说用在什么场景下?
worker是进程,里面是线程,再里面是可以动态调整的task,storm内部机制就是这么规划的
一般情况下一个exe一个task,但是也可多个task
这个我知道,这两个都可以谁知,那在实际项目中会让人头疼,设置几个executor,设计几个task在topology中设置呢?还是说只设置task的数量就好了?那个设置多点好呢?那个设置多,有什么区别
这种就要看你多少数据,多少资源,能否处理的过来,需要在你测试机器上跑一遍拿到一个参考数据才行,没人能告诉你具体如何设置,因为资源数据都不知道
登录后可查看更多问答,登录/注册
深入Storm内部机制,logstash+kafka,快速切入大数据实时流处理
1.0k 15
994 12
1.1k 12
720 11
1.0k 10