Could not find any factories that implement 'org.apache.flink.table.delegation.ExecutorFactory' in the classpath , maven
时间: 2023-12-22 20:16:02 浏览: 328
涨姿势:SpringBoot2.x启动全过程源码分析
如果你在使用 Flink Table API 或者 Flink SQL 时出现 `Could not find any factories that implement 'org.apache.flink.table.delegation.ExecutorFactory' in the classpath` 错误,通常是因为缺少对应的实现类依赖。你需要在 Maven 的 `pom.xml` 文件中添加对应的依赖。
如果你是在 Flink 的批处理模式下使用 Table API 或者 Flink SQL,需要添加以下依赖:
```xml
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_2.11</artifactId>
<version>${flink.version}</version>
</dependency>
```
如果你是在 Flink 的流处理模式下使用 Table API 或者 Flink SQL,需要添加以下依赖:
```xml
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_2.11</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
</dependency>
```
其中 `${flink.version}` 和 `${scala.binary.version}` 需要替换为你使用的 Flink 版本号和 Scala 版本号。这样,在 Maven 构建时,就会自动下载并添加 Flink Table API 的实现类依赖,你就可以正常使用 Table API 或者 Flink SQL 了。
阅读全文