Flink Table & sql执行报错：
Exception in thread "main" org.apache.flink.table.api.TableException: Could not instantiate the executor. Make sure a planner module is on the classpath
at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.lookupExecutor(StreamTableEnvironmentImpl.java:185)
at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.create(StreamTableEnvironmentImpl.java:148)
at org.apache.flink.table.api.bridge.java.StreamTableEnvironment.create(StreamTableEnvironment.java:128)
at org.apache.flink.table.api.bridge.java.StreamTableEnvironment.create(StreamTableEnvironment.java:96)
at com.itzhimei.tablesql.Test1.main(Test1.java:14)
Caused by: org.apache.flink.table.api.ValidationException: Could not find any factories that implement 'org.apache.flink.table.delegation.ExecutorFactory' in the classpath.
at org.apache.flink.table.factories.FactoryUtil.discoverFactory(FactoryUtil.java:387)
at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.lookupExecutor(StreamTableEnvironmentImpl.java:176)
... 4 more原因是因为代码和pom引入的jar不一致。
我当前测试代码的Flink版本是参考1.14.3， 我当前pom引入的jar版本是1.15.0。
目前官网的内容，较多地方都是代码演示和实际的pom版本不一致， 我当前参考的是官网提示的引入版本1.15.0，同时我编写测试代码也是同样参考了官网的demo，结果报错如上，所以还是要基于对应版本的api进行学习。
注意：在使用Flink Table & sql时，你代码api和pom引入到底是哪个版本，一定要注意分清楚。
例如Flink 1.11版本，pom引入如下：
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
</dependency>Flink 1.14.3版本，pom引入如下：
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner_2.11</artifactId>
<version>${flink.version}</version>
</dependency>Flink 1.15.0版本，pom引入如下：
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-api-java-bridge_2.11</artifactId>
<version>${flink.version}</version>
</dependency>API和版本对应不上，你在学习的时候，就会出现各种奇怪的问题，并且，你在百度的时候，你会发现，你的问题明明和百度中的问题一样，但是你按照说明来解决，问题就是解决不掉。