Hey Gyula, On 21 Jan 2015, at 15:41, Gyula Fóra <gyf...@apache.org> 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.
