赞
踩
报错信息:
Exception in thread "main" java.lang.IllegalStateException: No ExecutorFactory found to execute the application.
原因:
根据发布记录的描述,flink 1.11.0之后,flink-streaming-java模块不再依赖flink-clients,因此在Idea中运行flink程序时,应显式添加flink-clients模块依赖包。
处理办法:
pom.xml文件中引入依赖:
- <dependency>
- <groupId>org.apache.flink</groupId>
- <artifactId>flink-clients_${scala.version}</artifactId>
- <version>${flink.version}</version>
- </dependency>
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。