自动优化Storm并行度的方法、终端设备及存储介质

摘要

本发明公开一种自动优化Storm并行度的方法，包括如下步骤，S1：设置初始并行度Nmax和最小观察时长T，进入S2；S2：配置并保存并行度N及相关参数，进入S3；S3：提交计算拓扑到Storm集群，进入S4；S4：开始观察，对定时器、每个消息源和消息处理者的执行时长和执行次数清零，进入S5；S5：累加并记录观察时长T0和每个消息源和消息处理者的执行时长和执行次数，直到T0大于或等于T，进入S6；S6：计算每个消息源和消息处理者的实时并行度，并和各自的N进行比较，若相等，则返回S4，否则进入S7；S7：将S6中计算的实时并行度赋值给并行度N并保存，此时若Storm停止运行，则退出，否则返回S4。