flink testing

2017-04-22 Thread Georg Heiler
Hi, is there something like spark-testing-base for flink as well? Cheers, Georg

Re: Why TimerService interface in ProcessFunction doesn't have deleteEventTimeTimer

2017-04-22 Thread Ted Yu
Logged FLINK-6359, referring to this thread. FYI On Sat, Apr 22, 2017 at 1:10 AM, Gyula Fóra wrote: > Hi, > > I am not familiar with this data structure, I will try to read up on it. > But it looks interesting. > > For some reference, some links: > > https://www.confluent.io/blog/apache-kafka-p

Benchmarking Apache Flink via Query Plan

2017-04-22 Thread giacom...@libero.it
Plus, I'm currently using 1.1.2 and I cannot change version due to dependency problems. Thanks in advance, Giacomo90 >Messaggio originale >From: "giacom...@libero.it" >Date: 21/04/2017 17.42 >To: >Subj: R: WELCOME to user@flink.apache.org > >Dear Users and Apache Flink devs, > >

Re: Why TimerService interface in ProcessFunction doesn't have deleteEventTimeTimer

2017-04-22 Thread Gyula Fóra
Hi, I am not familiar with this data structure, I will try to read up on it. But it looks interesting. For some reference, some links: https://www.confluent.io/blog/apache-kafka-purgatory-hierarchical-timing-wheels/ http://www.cs.columbia.edu/~nahum/w6998/papers/sosp87-timing-wheels.pdf Cheers