Hi!
Another solution would be to locally install kafka+zookeeper and push your
dumped json (from the production server) data in a topic(you create a Kafka
producer).
Then you configure your code to point to this local broker. Consume your
data from topic from either strategy you need (earliest o
k(maxTimestamp);
>}
> }
>
>
> Regards,
> Dian
>
> 在 2018年12月13日，上午12:06，Andrey Zagrebin 写道：
>
> Hi Florin,
>
> I think Dawid might help you. I am pulling him into the discussion.
>
> Best,
> Andrey
>
> On 12 Dec 2018, at 16:24, Spico Florin wrote
Hello!
I'm using the same questions as in this stackoverflow post
https://stackoverflow.com/questions/50356981/apache-flink-cep-how-to-detect-if-event-did-not-occur-within-x-seconds?rq=1,
due to fact that I need the same functionality.
My use case is to detect when an device is disconnected from a
Hello!
I have used with success Flink with Docker, the approach presented in this
article:
http://diegoreico.com/environments/runningflinkgclusterwithzeppelin/
It it using a older version of Flink (1.4.2) in order to be compatible with
Zeppelin client, but you can check if it works with new vers
Hello!
I would like to ask you if you have added the support for CEP for match
involving fields of previous events, the same that was asked here:
"However it would be great to create Pattern out of a capability like:
.where(second_evt->evt.getTemperature()
== first_evt->evt.getTemperature()"
ht
Hello!
I'm using Flink 1.4.2 and I would like to use a group by operator based on
value of my event stream. The functionality that I would like to achieve is
similar to the following Esper EPL
(excerpt
http://esper.espertech.com/release-5.2.0/esper-reference/html/epl_clauses.html#epl-grouping-aggr
