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
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 =
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