第一次使用flink-java做一个wordcount就碰到了错误

1. java.lang.NoSuchFieldError: INSTANCE
   jar包冲突，flink-java，flink-streaming版本要一致，当然也有scala的版本
2. A typical reason for AskTimeoutException is that the recipient actor didn’t send a reply
   解决办法升级flink的jar包版本
   网上有升级jdk版本的，和增大响应时间的不知道有没有用
   依赖修改为

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.11</artifactId>
<version>1.12.0</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.flink/flink-java -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
<version>1.12.0</version>
</dependency>

3. No ExecutorFactory found to execute the application 这个错误需要再添加一个依赖

    <!-- https://mvnrepository.com/artifact/org.apache.flink/flink-clients
   没有这个依赖会爆 -->
   <dependency>
   <groupId>org.apache.flink</groupId>
   <artifactId>flink-clients_2.11</artifactId>
   <version>1.12.0</version>
   </dependency>
   

最后

以上就是傻傻白猫为你收集整理的flink初使用报错第一次使用flink-java做一个wordcount就碰到了错误的全部内容，希望文章能够帮你解决flink初使用报错第一次使用flink-java做一个wordcount就碰到了错误所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。