全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

Flink运行报错：Could not find any factories that implement ExecutorFactory

提问者：帅平问题分类：大数据

Flink版本1.17.0，运行table api的时候报错了，提示：

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.internal.AbstractStreamTableEnvironmentImpl.lookupExecutor(AbstractStreamTableEnvironmentImpl.java:109)
	at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.create(StreamTableEnvironmentImpl.java:101)
	at org.apache.flink.table.api.bridge.java.StreamTableEnvironment.create(StreamTableEnvironment.java:122)
	at org.example.sql.TableApiHelloword.main(TableApiHelloword.java:27)
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:534)
	at org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.lookupExecutor(AbstractStreamTableEnvironmentImpl.java:106)
	... 3 more

这个意思是没有执行器的配置，这个要怎么配置啊？

Flink

发布于：1年前 (2023-08-17) IP属地：四川省

1 个回答

つ浅笑嫣然

这是没有引入planner依赖，引入下即可，flink1.17.0版本引入的依赖是：

<dependency>
			<groupId>org.apache.flink</groupId>
			<artifactId>flink-table-planner_2.12</artifactId>
			<version>1.17.0</version>
		</dependency>

发布于：1年前 (2023-08-17) IP属地：四川省

我来回答