flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: Questions about slot sharing
Date Thu, 14 Jul 2016 12:55:25 GMT
Hi Huafeng,

yes, the mapper and reducer are running in different threads on the
TaskManager. Slot sharing is an abstract concept of the scheduler.

Flink also supports thread-sharing, for example when you have a series of
mappers (or filters) running with the same parallelism. We call this
feature "operator chaining" [1]



On Thu, Jul 14, 2016 at 10:37 AM, Vincent Wang <fvunicorn@gmail.com> wrote:

> Hi all,
>   I'm totally new to Flink and I got a question about Flink's slot sharing
> feature.
>   Suppose I have a pipeline like *Mapper-> Reducer, *and of cause the
> operators are* not *chained to a single task.
>   When the job is actually scheduled to the Flink cluster, there is a
> Mapper task and a Reducer task scheduled to the same TaskManager's slot,
> here slot sharing works.
>   The question is:  the slot sharing is an abstract concept, sharing slot
> doesn't means sharing thread, is that right? The Mapper task and Reducer
> task are still launched in independent threads.
> Thanks in advance.
> Thanks,
> Huafeng

View raw message