在Storm中配置并行性

作者: Coolkid
发布时间: 2024-02-25 04:46:27 (2月前)
转自：

2 条回复

0#
回复此人
与之 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 一，基础知识： </p> <OL> <LI> Workers - 运行执行程序，每个worker都有自己的JVM </LI> <LI> 执行者 - 运行任务，每个执行者都是风暴分布在各个工作人员身上 </LI> <LI> 任务 - 运行spout / bolt代码的实例 </LI> </醇> <P> 第二，纠正......有5名工人并不意味着你会自动拥有5份你的喷口。拥有5个工作人员意味着你有5个独立的JVM，其中storm可以分配执行程序来运行（将其视为5个存储桶）。 </p> <P> 首次创建和提交拓扑时，将配置您的喷口实例数： </p> <pre> <code> TopologyBuilder builder = new TopologyBuilder(); builder.setSpout("0-spout", new MySpout(), spoutParallelism).setNumTasks(spoutTasks); </code> </pre> <P> 由于整个群集只需要一个喷口，因此您需要设置两个喷口 <code> spoutParallelism </code> 和 <code> spoutTasks </code> 到1。 </p> </DIV>

编辑

登录后才能参与评论