一开始我使用的flink 版本为1.13.1,后面启动后报下面错误:
No ExecutorFactory found to execute the application.
原因:flink在使用1.10 以上的版本时,需要手动添加flink-clients的依赖,具体可参考
org.apache.flink flink-clients_2.121.13.1
当然也可以把flink版本降到1.10
解决:我把flink版本降到了1.10
org.apache.flink flink-java1.10.1 org.apache.flink flink-streaming-java_2.111.10.1 org.apache.flink flink-clients_2.111.10.1
重新clean install 一下maven项目,然后记得要Reload project 一下项目,否则你项目用的还是1.13.1版本的jar包
效果:问题解决



