Flink SQL 执行计划的查看方法

Flink

SQL

执行计划的查看方法

Flink

SQL

提供了多种查看执行计划的方法，以下是详细的步骤和参考材料：

方法一：使用

`env.getExecutionPlan()`

方法获取执行计划

JSON

1.在你的

FlinkJob

的

Main

方法里面加上

`System.out.println(env.getExecutionPlan());`

这行代码。

2.然后就可以在

IDEA

中右键

Run

一下你的

FlinkJob，从打印的日志里面可以查看到执行计划的

JSON

串。

方法二：使用

Flink

自带的可视化工具查看执行计划

1.将上述任一方式执行产生的

json

***出来。

2.打开生成

Flink

执行计划的网站

https://flink.apache.org/visualizer/

并把

json

***粘贴到网址去。

3.点击

Draw

按钮，就会生成执行流程图了。

方法三：使用

`tableEnv.explainSql(select字符串)`

方法查看执行计划

1.在新版本的

Flink

中，你可以使用

`tableEnv.explainSql(select字符串)`

方法来查看

SQL

查询的执行计划。

以上就是在

Flink

中查看

SQL

执行计划的常用方法。通过查看执行计划，你可以更好地理解

Flink

是如何执行你的

SQL

查询的，这对于优化查询语句和提高查询性能非常有帮助。