Hi,
here is an example input that produces the error. These are read from Kafka.
01:43:43.5921 2121{"Pressure target - Value":"6"}
01:43:43.5961 2121{"Flow target - Value":"23"}
01:43:44.2631 2121{"Pressure target - Value":"7"}
01:43:44.9721 2121
Hi Till,
thank you. here's the code:
public class CepStorzSimulator {
public static void main(String[] args) throws Exception {
final ParameterTool parameterTool =
ParameterTool.fromArgs(args);
if(parameter
Hi Till,
I used Flink version 1.0.0 and tried all three TimeCharacteristics.
Not I tried the new Flink 1.0.1 that gives me the following error.
After detecting an event it processes a few stream tuples but then crashes.
I'm not sure how to solve that part of the error message: "This can indicate
t
Hi,
I'm trying out the new CEP library but have some problems with event
detection.
In my case Flink detects the event pattern: A followed by B within 10
seconds.
But short time after event detection when the event pattern isn't matched
anymore, the program crashes with the error message:
04/06/20
