Re: Questions about FoldFunction and WindowFunction

Hi Yassine, I made you a contributor in the Flink Jira so you will be able to assign issues to yourself in the future. I also assigned this issue to you. I think you only need to do changes in WindwedStream and AllWindowedStream. Let me know if you need anything. :-) Cheers, Aljoscha On Wed, 2

Re: Questions about FoldFunction and WindowFunction

Yes, with please. Could you please assign it temporarily to me? (I am not very familiar with the internal components of Flink and migh take some time before contributing the code, if by the time you are ready to work on it I am not yet done, you can reassign it to yourself) 2016-11-02 14:07

Re: Questions about FoldFunction and WindowFunction

Would you be interested in contributing a fix for that? Otherwise I'll probably fix work on that in the coming weeks. On Wed, 2 Nov 2016 at 13:38 Yassine MARZOUGUI wrote: > Thank you Aljoscha for your quick response. > > Best, > Yassine > > 2016-11-02 12:30 GMT+01:00

Re: Questions about FoldFunction and WindowFunction

Thank you Aljoscha for your quick response. Best, Yassine 2016-11-02 12:30 GMT+01:00 Aljoscha Krettek : > Hi Yassine, > > regarding 1. The close() method of the RichFoldFunction will only be > called at the very end of your streaming job, so in practise it will never > be

Re: Questions about FoldFunction and WindowFunction

Hi Yassine, regarding 1. The close() method of the RichFoldFunction will only be called at the very end of your streaming job, so in practise it will never be called. This is there because of batch jobs, where you have an actual end in your processing. regarding 2. I'm afraid you came across a