分享

通过setBolt分析:worker数,Bolt实例数,executor数,task数

阿飞 2014-4-22 16:38:07 发表于 常识型 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 0 8694
问题导读:
builder.setBolt("cpp", new CppBolt(), 3).setNumTasks(5).noneGrouping(pre_name);  
中各个函数的作用是什么?
参数1代表什么?
参数2代表什么?
参数3达标什么?








在创建Storm的Topology时,我们通常使用如下代码:
  1. builder.setBolt("cpp", new CppBolt(), 3).setNumTasks(5).noneGrouping(pre_name);
  2. Config conf = new Config();
  3. conf.setNumWorkers(3);
复制代码

参数1:bolt名称 "cpp"
参数2:bolt类型 CppBolt
参数3:bolt的并行数,parallelismNum,即运行topology时,该bolt的线程数

setNumTasks() 设置bolt的task数
noneGrouping()  设置输入流方式及字段

conf.setNumWorkers()设置worker数据。

经过多次试验总结,得出如下结论:

1)Topology的worker数通过config设置,即执行该topology的worker(java)进程数。它可以通过storm rebalance 命令任意调整。

2) Topology中某个bolt的executor数,即parallelismNum,即执行该bolt的线程数,在setBolt时由第三个参数指定。它可以通过storm rebalance 命令调整,但最大不能超过该bolt的task数;

3) bolt的task数,通过setNumTasks()设置。(也可不设置,默认取bolt的executor数),无法在运行时调整。

4)Bolt实例数,这个比较特别,它和task数相等。有多少个task就会new 多少个Bolt对象。而这些Bolt对象在运行时由Bolt的thread进行调度。也即是说

  1. builder.setBolt("cpp", new CppBolt(), 3).setNumTasks(5).noneGrouping(pre_name);
复制代码

会创建3个线程,但有内存中会5个CppBolt对象,三个线程调度5个对象。




没找到任何评论,期待你打破沉寂

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条