Re: realtion between operator and task

2016-03-16 Thread Till Rohrmann
> > > > *From:* ewenstep...@gmail.com [mailto:ewenstep...@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 > > > > Hi! > > > > A "task&qu

RE: realtion between operator and task

2016-03-08 Thread Radu Tudoran
Hi, Thanks for the answer. Can you point me to the code where the operators are being assign to tasks. Thanks From: ewenstep...@gmail.com [mailto:ewenstep...@gmail.com] On Behalf Of Stephan Ewen Sent: Monday, March 07, 2016 8:29 PM To: user@flink.apache.org Subject: Re: realtion between

Re: realtion between operator and task

2016-03-07 Thread Stephan Ewen
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