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

这个意思是没有执行器的配置,这个要怎么配置啊?
1 个回答
つ浅笑嫣然
つ浅笑嫣然
这是没有引入planner依赖,引入下即可,flink1.17.0版本引入的依赖是:
<dependency>
			<groupId>org.apache.flink</groupId>
			<artifactId>flink-table-planner_2.12</artifactId>
			<version>1.17.0</version>
		</dependency>
发布于:11个月前 (08-17) IP属地:四川省
我来回答