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作业。