参考:
https://nightlies.apache.org/flink/flink-docs-release-1.17/zh/docs/dev/table/sql/explain/
EXPLAIN 语句
EXPLAIN 语句用于解释 query 或 INSERT 语句的执行逻辑,也用于优化 query 语句的查询计划。
执行 EXPLAIN 语句
EXPLAIN PLAN FOR [SQL 语句]
EXPLAIN ESTIMATED_COST, CHANGELOG_MODE, PLAN_ADVICE, JSON_EXECUTION_PLAN [SQL 语句]
ExplainDetails
使用指定的 ExplainDetail 类型来打印语句的计划。
ESTIMATED_COST
指定 ESTIMATED_COST 将使得优化器(optimizer)将估算出的成本信息附加在每个物理节点上输出。
CHANGELOG_MODE
指定 CHANGELOG_MODE 将使得优化器(optimizer)将 changelog mode 附加在每个物理节点上输出。
PLAN_ADVICE
从 Flink 1.17 版本开始支持 PLAN_ADVICE。
指定 PLAN_ADVICE 将使得优化器(optimizer)分析优化后的物理执行计划并提供潜在的数据风险预警或性能调优建议。
此时输出标题将会从 “Optimized Physical Plan” 变为 “Optimized Physical Plan with Advice” 作为提示。