storm原理
2019-02-15 17:36:30 0 举报storm原理解析
作者其他创作
大纲/内容
异或算法0101010111111111
线程
work(进程)6701
bolt
work
500/s
nimbus
task
spout
一个work中默认只有一个ackbolt
ack数据不丢失原理
不确认状态 内存会溢出
下载任务
supervisor
并行度为2
异或算法保存状态
算上默认的bolt 一共7个task
WorkAndScoreMap
进程:资源分配的最小单位(cpu和内存)线程:cpu调度任务最小单位
发送状态
② nimbus获取节点信息 分配任务
① 任务提交
250/s
zookeeper
cpu
ackbolt
③supervisor下载任务
./storm jar xxx.jar xxxx.TopologyMain wordcount
work (进程) 6700
1000/s
i
i love u
0 条评论
下一页
