官术网_书友最值得收藏!

Task

This is the most granular unit of task execution in Storm. Each task is an instance of a spout or bolt. When defining a Storm topology, you can specify the number of tasks for each spout and bolt. Once defined, the number of tasks cannot be changed for a component at runtime. Each task can be executed alone or with another task of the same type, or another instance of the same spout or bolt.

The following diagram depicts the relationship between a worker process, executors, and tasks. In the following diagram, there are two executors for each component, with each hosting a different number of tasks.

Also, as you can see, there are two executors and eight tasks defined for one component (each executor is hosting four tasks). If you are not getting enough performance out of this configuration, you can easily change the number of executors for the component to four or eight to increase performance and the tasks will be uniformly distributed between all executors of that component. The following diagrams show the relationship between executor, task, and worker:

主站蜘蛛池模板: 江山市| 仙桃市| 德保县| 德庆县| 迁西县| 驻马店市| 乐清市| 罗甸县| 且末县| 莎车县| 额敏县| 开鲁县| 富裕县| 德安县| 报价| 长子县| 江安县| 中江县| 南投市| 东光县| 利辛县| 开远市| 东至县| 通州市| 合阳县| 长海县| 元江| 济阳县| 汨罗市| 灯塔市| 云霄县| 江门市| 大石桥市| 新源县| 洪江市| 山西省| 都匀市| 诏安县| 伊宁市| 阳春市| 布尔津县|