【摘要】大量研究提出了从在线资源管理层面来优化波动数据流的方法,却忽略了从流应用层面来优化算子并行度.例如,在Apache Storm中,算子并行度一旦设置就无法进行动态调整.该文提出了一种针对波动数据流的算子智能并行化策略As-Stream,显著提升了流计算平台的性能.该方法在弹性智能监控模块中基于无监督学习和自适应分析对参数进行实时调优.As-Stream包括并行瓶颈识别、参数计划生成、参数迁移转换和参数迁移调度算法.该系统在Apache Storm平台上实现,并在真实的分布式流计算环境中进行了大量测试.结果表明,As-Stream性能比现有通用调度策略有显著提升:当资源充足时,平均吞吐量提高了2.4倍;当资源受限时,平均延迟减小了44%.