一种基于动态拓扑的流计算性能优化方法及其在Storm中的实现

• 作者: 吴涵 张元鸣 梁倩卉 肖刚 陆佳炜 陈烘
• 来源期刊: 电子学报
• 学科: 工学
• 关键词: 数据流拓扑 流计算 大数据 流计算系统 性能优化
• 年，卷（期）: 2020,（5）
• 所属期刊栏目: 学术论文
• 页码范围: 878-890
• 页数: 13页
• 分类号: TP311.13
• 字数: 8913字
• 语种: 中文
• DOI: 10.3969/j.issn.0372-2112.2020.05.007

摘要

响应性和稳定性一直是流式计算中两个至关重要的问题,而流计算系统在过载时常常表现出数据计算延迟增加和拓扑不稳定的现象,无法适应数据负载的动态变化.针对这一问题本文研究提出了一种基于动态拓扑的流计算性能优化方法,主要包括:(1)动态逐级反压:拓扑中的任务可以根据当前自身负载情况,动态调整上游向其发送数据的速率.(2)无状态拓扑数据重放:拓扑不维持数据的计算状态,尽可能地实现数据容错.(3)自适应拓扑替换:在拓扑不暂停的情况下对任务并发度进行自发调整.(4)延迟持久化队列:拓扑中对磁盘的IO读写被延迟到数据处理之外,减缓IO高频阻塞对流计算系统的影响.本文在Apache Storm中实现了以上四种方案,性能测试结果表明优化后的流计算系统与Storm默认实现相比,不仅增强了大数据动态匹配能力,而且在最优情况下改善了17％的吞吐量,并提升了约20％的数据处理速度.

作者信息

序号	姓名	单位	发文数	被引次数	H指数	G指数
1	张元鸣	浙江工业大学计算机科学与技术学院	65	493	11.0	19.0
2	陆佳炜	浙江工业大学计算机科学与技术学院	49	189	7.0	10.0
3	肖刚	浙江工业大学计算机科学与技术学院	138	1143	17.0	27.0
4	吴涵	浙江工业大学计算机科学与技术学院	1	0	0.0	0.0
5	梁倩卉	南洋理工大学计算机科学与工程学院	1	0	0.0	0.0