flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Luis Lázaro <lalaz...@keedio.com>
Subject Re: Generate Timestamps and emit Watermarks - unordered events - Kafka source
Date Tue, 25 Apr 2017 10:30:56 GMT
Hi Aljoscha and Kostas, thanks in advance.

Kostas, i followed your recommendation and it seems to be working fine.

I did:
- upgrade to 1.3.-SNAPSHOT from master branch.
- try assign timestamp and emit watermarks using AscendingTimestampExtractor: alerts are correct
(do not process late events as normal ones) and i get a lot of warning about violated ascending
monotony (its ok, my events are not ordered in time).
- try assign timestamp and emit watermarks using BoundedOutOfOrdernessTimestampExtractor:
alerts are correct.

Thanks a lot, 
best regards, Luis.

View raw message