本文介绍了Apache Flink-wordcount-NoResourceAvailableException的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
安装(下载&;tar zxf)Apache Flink 1.11.1并运行:./bin/flink run examples/streaming/WordCount.jar
大于等于5分钟后显示在友好消息上。提交尝试: Caused by: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not allocate the required slot within slot request timeout. Please make sure that the cluster has enough resources.
at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeWrapWithNoResourceAvailableException(DefaultScheduler.java:441)
... 45 more
Caused by: java.util.concurrent.CompletionException: java.util.concurrent.TimeoutException
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:607)
at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
这是Flink默认配置。
Architecture: x86_64
CPU op-mode(s): 32-bit, 64-bit
Byte Order: Little Endian
CPU(s): 8
On-line CPU(s) list: 0-7
Thread(s) per core: 1
Core(s) per socket: 1
free-g
total used free shared buff/cache available
Mem: 62 1 23 3 37 57
Swap: 7 0 7
这里发生了什么事有什么建议吗?
推荐答案
此问题已在Flink 1.11.3中修复。Refer this link。
这篇关于Apache Flink-wordcount-NoResourceAvailableException的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!