Thank you! I will play around with it. On Wed, Jan 21, 2015 at 3:50 PM, Ufuk Celebi <[email protected]> wrote:
> Hey Gyula, > > On 21 Jan 2015, at 15:41, Gyula Fóra <[email protected]> wrote: > > > Hey Guys, > > > > I think it would make sense to turn lazy operator execution off for > > streaming programs because it would make life simpler for windowing. I > > also created a JIRA issue here > > <https://issues.apache.org/jira/browse/FLINK-1425>. > > > > Can anyone give me some quick pointers how to do this? Its probably > simple, > > I am just not familiar with that part of the code. (Or maybe its so easy > > that someone could pick this up :) ) > > Have a look at the JobManager ScheduleOrUpdateConsumers message, which is > how it is done currently. The first produced buffer of an intermediate > results triggers this message. I think the cleanest solution would be to do > this directly when scheduling a streaming job? > > > By the way, do you see any reasons why we should not do this? > > ATM, I don't.
