FlinkSQL 使用Object复用特性提升FlinkSQL计算性能
使用场景
针对Table API开发的SQL业务,使用Object复用特性可以提升SQL的计算性能。
使用限制
- 该特性仅对Table API开发的SQL业务有效。
- 为保证计算准确性,FlinkSQL UDF中的Object无法复用。
- 本章节仅适用于MRS 3.6.0-LTS及之后版本。
使用方法
配置Flink作业时,可通过在FlinkServer WebUI的Flink作业开发界面添加自定义参数“pipeline.serialization-elimination”为“true”开启Object复用功能,可参考创建FlinkServer作业。