FlinkSQL 使用RocksDB Merge Operator提升Join算子性能
使用场景
针对包含NoUniqueKey的Join算子,使用该特性可以提升Join算子的计算性能。
使用限制
- 仅使用RocksDB状态后端时,该特性会提升Join算子的计算性能。
- 开启该特性前后生成的快照,互相不兼容。
- 本章节仅适用于MRS 3.6.0-LTS及之后版本。
使用方法
配置Flink作业时,可通过在FlinkServer WebUI的Flink作业开发界面添加自定义参数“table.exec.join.use-merge-operator”为“true”开启MergeOperator功能,可参考创建FlinkServer作业。