摘要: 部分用户(尤其对外输出)使用MaxCompute(原Odps)时,由于对产品的使用层面和执行层面了解程度不同,导致提交的任务执行时间过长、占用了较多集群资源;严重的会导致失败、不仅需要投入支持同学精力协助解决、也影响了用户正常业务。 合并整理部分性能提升方法方
转载自xiaorui
部分用户(尤其对外输出)使用MaxCompute(原Odps)时,由于对产品的使用层面和执行层面了解程度不同,导致提交的任务执行时间过长、占用了较多集群资源;严重的会导致失败、不仅需要投入支持同学精力协助解决、也影响了用户正常业务。 合并整理部分性能提升方法方便支持用户查询和优化Sql,提高效率;部分需要原来手动调优的如mapjoin、ppd谓词下推注意分区位置等原有的调优设置在不断衍进的产品中都已实现了自动化调优、 不同阶段的产品调优参数和细节会有不一致、但是熟悉了调优思路和方法后可以做到举一反三、逐步深入。
一. 整体思路
整体上,调优从底层到sql可以有多个层面的调优,随着产品的不断完善,部分调优已经实现了自动化。如果用户能熟悉常见的调优机制和执行原理,在开发执行sql、业务逻辑和相关参数设置调整来提高性能、可以做到事半功倍。
1.硬件及操作系统层面调优:包括磁盘I/O调优(多路复用等)、网络调优(缓冲区大小、连接数放大等)、内存调优(虚拟内存设置、内存控制等);
2. 分布式计算平台及存储层面调优:存储格式设置、压缩格式设置、RPC调用设置、连接数控制设置、调度机制设置、block及分片设置、执行资源设置等;
3. 业务逻辑层面及参数调整,除整体执行的调优外,对不同类型的操作进行参数级别的调优、针对聚合、连接、一读多写等修改为不同的sql或者设置不同的参数可以极大的提高性能;
4. Sql层面及应用层面的调优,重构sql写法、合并sql,大小表连接修改为mapjoin等,在odps2.0中已处理了自动mapjoin等、目前未升级用户及对外输出的用户仍需要修改sql来支持;
不同层面调优及优缺点见下:
二. 场景及调优列举
1. 大小表关联修改为mapjoin,增加Mapjoin hint
方法及注意事项:
所有指定的小表占用的内存总和不超过 512M
多表Join时,最左边的两个表,不能同时是 Mapjoin 的表
不同的关联方式(left/right/inner),对表的顺序有要求
left outer join 左表必须为大表
right outer join 右表必须为大表
inner join 左右表皆可为大表
full outer join 不能直接使用 mapjoin,修改为mapjoin + union all
最新的发布版本上已经支持了automapjoin,可以根据join表的大小自动把小表转为mapjoin,对部分没有显示增加hint的sql和中间结果为小表的sql进行自动优化
2. 数据倾斜
数据倾斜表现:
任务进度长时间维持在99%,查看监控,只有少量 reduce 子任务未完成
单一 reduce 记录数与平均记录数差异多大,最长时长远大于平均时长
优化方法及注意事项:
聚合倾斜,设置参数:set odps.sql.groupby.skewindata=true
关联倾斜,设置参数:set odps.sql.skewinfo=tab1:(col1,col2)[(v1,v2),(v3,v4),...|(v1,v2),(v3,v4),...];set odps.sql.optimize.skewjoin=true
关联倾斜,同时大小表,考虑修改为mapjoin
具体问题具体分析:因为聚合key值null引起的数据倾斜,可以修改null为随机值,打撒数据分发到不同的instance执行
3. Map 端一读多写
场景及优化:
多次读取同一张物理表,执行不同操作,写入多张表;考虑与multiinsert 的联系和区别,是否合适做修改
建立临时表,实现临时表的并行化
注意事项:
优点:大大节省了集群的计算资源和磁盘I/O资源
缺点:写的次数非常多时,可能导致性能问题,影响任务整体执行效率
4 分区裁剪
场景:事实表很多分区,数据量大
优化:避免全表扫描,减少资源浪费;关注分区裁剪有无生效,见下注意事项:从表设计、使用上注意,尽量让分区裁剪生效
注意事项:
过滤条件中的分区列上有UDF 则分区裁剪生效
表关联时关联条件中包含分区列:
出现在 on 条件中,分区裁剪生效
出现在 where 条件中,主表分区裁剪生效,其余可能失败
5. SQL 合并
场景:
1. 多次读取相同的数据且源数据数据量大、性能差、费用高
2. 统一业务流程前后关联sql或统计多种指标、筛选不同数据的sql
优化方法及注意事项:通过修改sql,合并为1个sql执行,尽量减少对相同数据源的读取次数,达到一次扫描计算多个基础统计量,一次扫描,处理多个筛选条件;以下调整列举:
CASE … WHEN…:合并相同数据源的不同子查询的关联
动态分区&多路插入等:将满足不同条件的会员统计信息插入到不同的表或表分区中去
前后流程sql合并为1个sql执行
6 使用窗口函数优化SQL
窗口函数:
1. 可以进行灵活的分析处理工作
2. 使用 partition by 开窗,order by 排序
3. 可以用 rows 指定开窗范围
4.丰富的开窗函数
优化及注意事项:合理使用窗口函数,可以减少Join次数,提高运行性能;不用窗口函数处理需要写复杂sql的功能,用开窗函数可以高效执行得到预期结果。
原文链接:http://click.aliyun.com/m/45009/
分享到:
相关推荐
总结,万台集群的MaxCompute性能优化是一个系统性工程,涉及到SQL优化、数据分布、并行计算、资源管理等多个层面。通过细致的策略调整和持续的监控,可以显著提升MaxCompute处理大数据的能力,为企业的数据分析提供...
- **监控与调优**:定期对系统性能进行监控,并根据实际情况进行参数调优。 5. **安全与合规**: - **数据加密**:敏感数据在传输和存储过程中应进行加密,确保数据安全。 - **合规性检查**:遵循相关法规和标准...
此外,还可以通过MaxCompute的性能监控工具,如DataHub、ODPS Monitor等,了解系统运行状态,及时发现并解决问题。 总结,MaxCompute的索引优化实践主要集中在合理选择和设计分区,以及正确使用和调整索引策略上。...
同时,也会介绍如何根据监控数据进行性能调优,以提升系统的整体效率。 8. **高可用性与容灾**:MaxCompute可能具有高可用的特性,即使在部分节点故障的情况下,也能保证服务的连续性。文档可能包含关于故障转移和...
6. **性能调优**:提供性能优化的最佳实践,如分区策略、表设计、查询优化等。 7. **故障排查**:列举常见问题和解决办法,帮助用户快速定位和解决问题。 8. **案例实践**:分享实际业务场景下的应用案例,帮助...
4. 性能调优:通过对系统性能的深度分析,找出瓶颈并进行优化,提升数据处理效率,保证游戏数据分析的实时性。 5. 容量规划:根据历史数据和业务预测,合理规划资源容量,避免资源浪费和突发需求时的资源短缺。 6....
8. **监控与调优工具**:利用MaxCompute提供的监控工具,如DataHub、SQL分析等,实时查看任务执行情况,及时发现并解决问题。 9. **架构优化**:考虑引入数据湖或数据仓库架构,将冷数据分层存储,减少对热数据的...
5. **开发与调优**:文档会涵盖开发工具的使用,如Data IDE、SDK集成等,同时提供性能优化建议,如SQL优化、并行度调整、分区策略等。 6. **高可用与稳定性**:MaxCompute具有高可用性和容灾能力,用户应了解服务的...
6. 性能调优:提供调优建议,如索引建立、分区策略、内存配置等,提升查询速度和系统性能。 7. 监控与报警:介绍如何设置监控指标,及时发现并处理异常,以及设置报警规则,防止问题扩大化。 此外,文档可能还包括...