Re: Apache Flink Operator State as Query Cache

Hi Kostas, Yes. Exactly. Thanks a lot for this one. That's really what we need ! Cheers On Sun, Nov 15, 2015 at 8:53 PM, Kostas Tzoumas wrote: > Hi Wally, > > This version adds support for specifying and switching between time > semantics - processing time, ingestion

Custom TimestampExtractor and FlinkKafkaConsumer082

Hi everyone, I have the following issue with Flink (0.10) and Kafka. I am using a very simple TimestampExtractor like [1], which just extracts a millis timestamp from a POJO. In my streaming job, I read in these POJOs from Kafka using the FlinkKafkaConsumer082 like this: stream =

Different CoGroup behavior inside DeltaIteration

Hi, When running CoGroup between the solution set and a different dataset inside a DeltaIteration, the CoGroupFunction only get called for items that exist in the other dataset, simillar to an inner join. This is not the documented behavior for CoGroup: If a DataSet has a group with no