Storm topology求教?

孔***

builder.setSpout("spout",new RandomSentenceSpout(),5).setNumTasks(7);

5和7分别代表什么?

m6442***

5代表：5个初始执行线程（executor），这个东西是由worker生成的线程。在 executor 中可能会有一个或者多个 task，这些 task 都是为同一个组件（spout 或者 bolt）服务的。
7代表：7个task任务的数目，task 是实际执行数据处理的最小工作单元（注意，task 并不是线程）

已有账号？

找人解决需求

Storm topology求教?

全部参与1

热门问答

孔***

今日需求悬赏

今日问答求助

发布任务需求已有1031290位用户正在使用天盟网服务

新手帮助

平台规则

关于天盟

一键快捷导航

微信公众号

手机客户端