Hi! 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 -> ..." Stephan On Mon, Mar 7, 2016 at 7:36 PM, Radu Tudoran <radu.tudo...@huawei.com> wrote: > 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. >
