本文介紹了Apache Flink-wordcount-NoResourceAvailableException的處理方法，對大家解決問題具有一定的參考價值，需要的朋友們下面隨著小編來一起學習吧！

問題描述

安裝(下載&amp；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的文章就介紹到這了，希望我們推薦的答案對大家有所幫助，