FlinkSQL 使用Object复用特性提升FlinkSQL计算性能

使用场景

在FlinkSQL业务中，Table API开发的SQL业务在数据处理过程中会频繁创建和销毁对象（Object），导致大量的内存分配和垃圾回收（GC）开销，影响计算性能。开启Object复用特性后，FlinkSQL可在算子间复用数据传输对象，避免频繁的对象创建与销毁，从而提升SQL的计算性能。

约束与限制

• 该特性仅对Table API开发的SQL业务有效。
• 为保证计算准确性，FlinkSQL UDF中的Object无法复用。
• 本章节仅适用于MRS 3.6.0-LTS及之后版本。

使用方法

1. 登录Manager界面，选择“集群 > 服务 > Flink”，在“Flink WebUI”右侧，单击链接，访问FlinkServer的WebUI。
2. 单击“作业管理”进入作业管理页面。
3. 在FlinkServer作业管理界面，可参考集群连接模式创建Flink SQL作业选择已有作业或新建作业，进入作业开发界面。
4. 在作业开发界面的“自定义参数”配置“pipeline.serialization-elimination”的参数值为“true”开启Object复用功能。参数配置完成后，提交Flink作业即可生效。