Re: FlinkCEP latency/throughput

2017-05-19 Thread Dawid Wysakowicz
Hello Alfred, Just some considerations from my side as for the latency. I think the first step should be defining what does "latency" for a CEP library really means. The first thing that comes to my mind is the time period between the arrival of an event that should trigger a match (ending patter

Re: FlinkCEP latency/throughput

2017-05-19 Thread Sonex
Hello Kostas, thanks for your response. Regarding throughput, it makes sense. But there is still one question remaining. How can I measure the latency of my FlinkCEP application ??? Maybe you answered it, but I didn`t quite get that. As far as your number 2 question about measuring latency, the

Re: FlinkCEP latency/throughput

2017-05-17 Thread Dean Wampler
On Wed, May 17, 2017 at 10:34 AM, Kostas Kloudas < k.klou...@data-artisans.com> wrote: > Hello Alfred, > > As a first general remark, Flink was not optimized for multicore > deployments > but rather for distributed environments. This implies overheads > (serialization, > communication etc), when c

Re: FlinkCEP latency/throughput

2017-05-17 Thread Kostas Kloudas
Hello Alfred, As a first general remark, Flink was not optimized for multicore deployments but rather for distributed environments. This implies overheads (serialization, communication etc), when compared to libs optimized for multicores. So there may be libraries that are better optimized for t