Hi Chesnay, thank you very much for your help.
If naming datastreams, counter “Records sent” are correct, i.e.,
map.filter(condition1).name.filter(condition2).name
thanks,
best regards
Luis.
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
Hi everyone,
i am working on a use case with CEP and Flink:
Flink 1.2
Source is Kafka configured with one single partition.
Data are syslog standard messages parsed as LogEntry (object with attributes
like timestamp, service, severity, etc)
An event is a LogEntry.
If two consecutives LogEntry
