我正在为我的storm拓扑应用并行性。我已将工作节点数设置为1。
示例#1我将特定组件的任务数和执行器数设置为“2”。
示例#2:no of tasks<no of executors对于特定组件，我将任务数设置为“1”，执行器数设置为“2”。
示例#3:no of tasks>no of executors我正在将特定组件的任务数设置为“5”，执行器数设置为“1”。
我不知道上面的例子中哪一个会导致拓扑的最佳并行性，并建议哪一个会带来storm并行的好处？请帮助我理解这一点。
我正在为我的storm拓扑应用并行性。我已将工作节点数设置为1。
示例#1我将特定组件的任务数和执行器数设置为“2”。
示例#2:no of tasks<no of executors对于特定组件，我将任务数设置为“1”，执行器数设置为“2”。
示例#3:no of tasks>no of executors我正在将特定组件的任务数设置为“5”，执行器数设置为“1”。
我不知道上面的例子中哪一个会导致拓扑的最佳并行性，并建议哪一个会带来storm并行的好处？请帮助我理解这一点。
1条答案
按热度按时间h7wcgrx31#
你读过这篇文章吗？https://storm.apache.org/documentation/understanding-the-parallelism-of-a-storm-topology.html
为了获得良好的性能，应该将executors的数量设置为可用内核的数量（每个executors在自己的线程中运行）。只有当您想在运行时更改并行性时，使用比执行器更多的任务才是有益的。
您的“example#2”不是有效配置：#tasks>=#executors必须始终为true（否则，将存在没有工作的线程）。