flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: realtion between operator and task
Date Mon, 07 Mar 2016 19:28:31 GMT

A "task" is something that is deployed as one unit to the TaskManager and
runs in one thread.

A task can have multiple "operators" chained together, usually one per user
function, for example "Map -> Filter -> FlatMap -> AssignTimestamps -> ..."


On Mon, Mar 7, 2016 at 7:36 PM, Radu Tudoran <radu.tudoran@huawei.com>

> Hi,
> Can someone explain how and where a stream operator is mapped to a stream
> task.
> I am particularly interested in the way the stream outputs are created and
> attached to the operators. I saw that this happen in OperatorChain
> functions but I do not have the picture of the lifecycle of an stream
> operator that you would create to its mapping to the task and assignment of
> the output binding.

View raw message