Storm 扩展

https://blueprints.launchpad.net/sahara/+spec/storm-scaling

此蓝图旨在为 Storm 实现扩展功能。

问题描述

Sahara 中的 Storm 插件目前尚未实现扩展选项。此功能是使用 Sahara 构建集群的主要吸引力之一。

提议的变更

扩展功能的实现将遵循 Spark 插件的实现方式。

该实现将允许用户

• 扩展集群

• 缩减集群

Storm 是一个相对容易扩展的工具。由于它使用 Zookeeper 作为配置管理器和通信中心，新节点只需要配置自身以与 Zookeeper 机器通信，主节点就会发现新节点。需要考虑的一个重要点是 Storm 的重新平衡操作。一旦添加了新节点，正在运行的拓扑将不会被重新调度以使用新实例。我们将自动调用此重新平衡操作，以便用户无需担心此调用。

替代方案

无。

数据模型影响

无。

REST API 影响

无。

其他最终用户影响

无。

部署者影响

无。

开发者影响

无。

Sahara-image-elements impact

无。

Sahara-dashboard / Horizon 影响

无。

实现

负责人

主要负责人

tellesmvn

其他贡献者

工作项

• 实现 Storm 扩展功能

• 实现拓扑重新平衡

依赖项

无。

测试

参考其他插件的扩展测试示例，为 Storm 扩展实现单元测试。

文档影响

无。

参考资料

无。