Re: Kafka watermarks

2017-06-20 Thread nragon
I guess using BoundedOutOfOrdernessTimestampExtractor inside consumer will work. Thanks -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Kafka-watermarks-tp13849p13880.html Sent from the Apache Flink User Mailing List archive. mailing list

Re: Kafka watermarks

2017-06-20 Thread Nico Kruber
according to the javadoc of FlinkKafkaConsumerBase#assignTimestampsAndWatermarks(): "Specifies an {@link AssignerWithPunctuatedWatermarks} to emit watermarks in a punctuated manner. The watermark extractor will run per Kafka partition, watermarks will be merged across partitions in the same way

Re: Kafka watermarks

2017-06-20 Thread nragon
(consumer); dataStream. assignTimestampsAndWatermarks() Any recommendation? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Kafka-watermarks-tp13849p13872.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Kafka watermarks

2017-06-20 Thread Nico Kruber
Can you clarify a bit more on what you want to achieve? Also, what is "BOOTE"? Nico On Tuesday, 20 June 2017 13:45:06 CEST nragon wrote: > When consuming from kafka should we use BOOTE inside consumer or after? > Thanks > > > > -- > View this message in context: > http://apache-flink-user-mai

Kafka watermarks

2017-06-20 Thread nragon
When consuming from kafka should we use BOOTE inside consumer or after? Thanks -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Kafka-watermarks-tp13849.html Sent from the Apache Flink User Mailing List archive. mailing list archive at