Re: Fold vs Reduce in DataStream API

2015-12-31 Thread Aljoscha Krettek
No, the internal behavior is not documented right now. But I think it will change before the 1.0 release. > On 30 Dec 2015, at 18:44, Brian Chhun wrote: > > Thanks for the clarification. Is there a resource besides the code that has > these kinds of things documented? Understandable if there i

Re: 2015: A Year in Review for Apache Flink

2015-12-31 Thread Vasiliki Kalavri
Happy new year everyone! Looking forward to all the great things the Apache Flink community will accomplish in 2016 :)) Greetings from snowy Greece! -Vasia. On 31 December 2015 at 04:22, Henry Saputra wrote: > Dear All, > > It is almost end of 2015 and it has been busy and great year for Apache

Unit testing support for flink application?

2015-12-31 Thread Filipe Correia
Hi all, I'm finding it hard to unit test my Flink application. Are there any guidelines / best practices for unit testing a Flink application, especially for programming for the streaming API with Scala? Having a few good examples would also help a lot. I'm aware of flink-spector[1], and it look

Re: 2015: A Year in Review for Apache Flink

2015-12-31 Thread Slim Baltagi
Happy New Year to you and your families! Let’s make 2016 the year of Flink: General Availability, faster growth, wider industry adoption, … Slim Baltagi Chicago, US On Dec 31, 2015, at 5:05 AM, Vasiliki Kalavri wrote: > Happy new year everyone! > Looking forward to all the great things the Ap

Re: Unit testing support for flink application?

2015-12-31 Thread Stephan Ewen
Hi! Are you referring to testing streaming programs? What is the main obstacle for you? Generating test data streams? Thanks, Stephan On Thu, Dec 31, 2015 at 12:43 PM, Filipe Correia wrote: > Hi all, > > I'm finding it hard to unit test my Flink application. Are there any > guidelines / best