第一次使用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版本的，和增大响应时间的不知道有没有用
   依赖修改为

1
2
3
4
5
6
7
8
9
10
11
12
13

<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>

   1
   2
   3
   4
   5
   6
   7
   8
    <!-- 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就碰到了错误内容请搜索靠谱客的其他文章。