flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Radu Tudoran <radu.tudo...@huawei.com>
Subject RE: realtion between operator and task
Date Tue, 08 Mar 2016 09:51:44 GMT

Thanks for the answer. Can you point me to the code where the operators are being assign to

From: ewenstephan@gmail.com [mailto:ewenstephan@gmail.com] On Behalf Of Stephan Ewen
Sent: Monday, March 07, 2016 8:29 PM
To: user@flink.apache.org
Subject: Re: realtion between operator and task


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<mailto:radu.tudoran@huawei.com>>

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