文档首页/ MapReduce服务 MRS/ 组件操作指南(LTS版)/ 使用Flink/ Flink企业级能力增强/ FlinkSQL 使用PreState提升Join算子、TopN算子性能
更新时间:2025-12-10 GMT+08:00
分享

FlinkSQL 使用PreState提升Join算子、TopN算子性能

使用场景

针对使用了Join算子、TopN算子的业务SQL,使用PreState可以提升该类SQL的计算性能。

使用限制

  • 开启该特性前后生成的快照,互相不兼容。
  • 本章节仅适用于MRS 3.6.0-LTS及之后版本。

使用方法

配置Flink作业时,可通过在FlinkServer WebUI的Flink作业开发界面添加自定义参数“table.exec.use-map-pre-state”为“true”、“state.backend.rocksdb.auto-workload-parameters-derivation”为“true”开启PreState功能,可参考创建FlinkServer作业

相关文档