Re: No pooled slot available and request to ResourceManager for new slot failed

2020-10-28 文章 Yangze Guo
Hi,

你job的并发是多少?一共请求了多少个slot?
方便的话最好发一下jm的日志来帮助排查

Best,
Yangze Guo

On Thu, Oct 29, 2020 at 10:07 AM marble.zh...@coinflex.com.INVALID
 wrote:
>
> 大家好。
>
> 只有一个job,设置了jm/tm各总内存为3G,一个taskmanager,总共10个slot,为什么还是报这个错?
>
> Caused by:
> org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
> No pooled slot available and request to ResourceManager for new slot failed
> ... 27 more
>
> 有没有一些建议,谢谢。
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/


No pooled slot available and request to ResourceManager for new slot failed

2020-10-28 文章 marble.zh...@coinflex.com.INVALID
大家好。

只有一个job,设置了jm/tm各总内存为3G,一个taskmanager,总共10个slot,为什么还是报这个错?

Caused by:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
No pooled slot available and request to ResourceManager for new slot failed
... 27 more

有没有一些建议,谢谢。



--
Sent from: http://apache-flink.147419.n8.nabble.com/


No pooled slot available and request to ResourceManager for new slot failed

2020-10-28 文章 marble.zh...@coinflex.com.INVALID
大家好,

我已经分配了8个taskmanager.numberOfTaskSlots,但还是遇到如下exception,
我为job/task分配了每个3G的总内存。有没有什么建议?, 谢谢

Caused by:
org.apache.flink.runtime.resourcemanager.exceptions.UnfulfillableSlotRequestException:
Could not fulfill slot request 294b93e601744edd7be66dec41e8d8ed. Requested
resource profile (ResourceProfile{UNKNOWN}) is unfulfillable.
at
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl.lambda$fulfillPendingSlotRequestWithPendingTaskManagerSlot$11(SlotManagerImpl.java:883)
at
org.apache.flink.util.OptionalConsumer.ifNotPresent(OptionalConsumer.java:52)
at
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl.fulfillPendingSlotRequestWithPendingTaskManagerSlot(SlotManagerImpl.java:879)
at
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl.lambda$internalRequestSlot$9(SlotManagerImpl.java:866)
at
org.apache.flink.util.OptionalConsumer.ifNotPresent(OptionalConsumer.java:52)
at
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl.internalRequestSlot(SlotManagerImpl.java:866)
at
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl.registerSlotRequest(SlotManagerImpl.java:386)
... 26 more




--
Sent from: http://apache-flink.147419.n8.nabble.com/