1、 No ExecutorFactory found to execute the application.

原因: 缺少 flink-client jar,引入即可解决问题,但是因为引入的时候对配置参数不熟悉,引入出错
方法一:直接在pom.xml文件中加入对应版本的jar包,然后更新maven

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-clients_2.11</artifactId>
    <version>1.12.1</version>
    <!--            <scope>provided</scope>-->
    <!--有的会将这个加入,但是测试发现,加入这个后会依然报错,具体原因未知 -->
</dependency>

这种方法只要版本好正确就可以,没有其他问题。版本不确定可以在输入的时候查看提示信息即可(IDEA编辑下)
方法二:不写固定版本进行导入,然后更新maven

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-clients_${scala.binary.version}</artifactId>
    <version>${flink.version}</version>
<!--            <scope>provided</scope>-->
<!--有的会将这个加入,但是测试发现,加入这个后会依然报错,具体原因未知 -->
</dependency>

开始使用的这个配置方法,但是发现$后的参数报错,报错原因是properties没有配置,
配置前:

<properties>
    <maven.compiler.source>8</maven.compiler.source>
    <maven.compiler.target>8</maven.compiler.target>
</properties>

配置后:

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <flink.version>1.12.0</flink.version>
    <target.java.version>1.8</target.java.version>
    <scala.binary.version>2.11</scala.binary.version>
    <maven.compiler.source>${target.java.version}</maven.compiler.source>
    <maven.compiler.target>${target.java.version}</maven.compiler.target>
</properties>

版本号按照配置环境进行配置,小白暂时没有发现快捷的配置方法,后续更新。

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐