flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: How Flink decide which slots to use?
Date Thu, 01 Dec 2016 11:59:21 GMT
+Till since he is working a lot in these parts.

Could you maybe shed some light on this?

On Mon, 28 Nov 2016 at 11:34 Renkai Ge <gaelookair@gmail.com> wrote:

> I have 8 machine and I started a taskmanager with 24 slots on every
> machine.At first, I submited two apps, each of them used 8 slots, the all
> consumed one slot on each machine in the cluster.
> [image: 屏幕快照 2016-11-28 18.18.51.png]
>
> Then I submited another application, but it behaves different, it used 8
> slots,too. But 4 of them are run on the same machine.
> [image: 屏幕快照 2016-11-28 18.21.52.png]
>
> [image: 屏幕快照 2016-11-28 18.22.31.png]
>
> Since this application used a lot of memory, such dispatch may cause a
> memory overflow. I want to know if I can custom the slot dispatcher.
>

Mime
View raw message