问题标签 [apache-storm-topology]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
0 回答
14 浏览

apache-storm - 如何设置 Apache Storm (2.2.1) worker 内存限制?

我将 Apache Storm 从 1.1.1 更新到 2.2.1,使用相同的配置和拓扑。但是 2.2.1 不能启动工作进程。这是我的配置:

以及 nimbus.log 中的日志:

不同形式的ui: 1.1.1 2.2.1

我发现主管在启动工作进程时给出了参数“-Dworker.memory_limit_mb=24448”,但它与我的 worker.childopts 设置不匹配。

此拓扑有 7600 个执行器/任务,运行在 40 个插槽上,因此每个插槽需要运行 380 个执行器/任务。在 v1.1.1 中,一切正常,但在 v2.2.1 中,似乎没有配置限制每个工作人员的内存,工作人员将分配 executors* topology.component.resources.onheap.memory.mb(default 128)

如何在 Apache Storm (2.2.1) 中设置工作内存限制或关闭 Resource Aware Scheduler ?