Flink SQL 1.11如何获取执行计划 & StreamGraph

[zilong xiao]

1.11好像改了接口，用StreamExecutionEnvironment.getExecutionPlan()会报"No operators
defined in streaming topology. Cannot execute." 1.10是可以正常执行的

[zilong xiao]

如题所说，以下是我个人分析，希望社区大佬帮忙看看是否正确，根据源码 遇到No
operators...异常的原因是transformations为空，在1.10版本，transformations的赋值动作(addOperator方法)在sqlUpdate()调用时触发，在1.11版本移除掉了该方法，transformations的赋值动作在statementSet.execute()时才会执行，是不是可以理解为transformations不会提前赋值，只有提交时才会初始化，所以在作业提交前无法获取作业的执行计划，我觉得这个是不是不太满足用户使用场景，不知道1.11这么做是有什么取舍吗？

zilong xiao <[hidden email]> 于2020年10月16日周五 下午8:56写道：

> 1.11好像改了接口，用StreamExecutionEnvironment.getExecutionPlan()会报"No operators
> defined in streaming topology. Cannot execute." 1.10是可以正常执行的
>