Hi Norman,
sorry for the late reply. I finally found time and could, thanks to you,
reproduce the problem. The problem was that the window borders were treated
differently in two parts of the code. Now the left border of a window is
inclusive and the right border (late elements) is exclusive. I've already
committed a fix for this problem and tested it with your example data. If
you use the latest master version, then your CEP example will now work :-)
Thanks for reporting the problem.
Cheers,
Till
On Thu, Apr 7, 2016 at 12:15 PM, norman sp <wir12...@studserv.uni-leipzig.de
> wrote:
> Hi,
> here is an example input that produces the error. These are read from
> Kafka.
>
> 01:43:43.592 1 2121 {"Pressure target - Value":"6"}
> 01:43:43.596 1 2121 {"Flow target - Value":"23"}
> 01:43:44.263 1 2121 {"Pressure target - Value":"7"}
> 01:43:44.972 1 2121 {"Flow target - Value":"24"}
> 01:43:45.176 1 2121 {"Flow target - Value":"25"}
> 01:43:45.279 1 2121 {"Flow target - Value":"26"}
> 01:43:45.382 1 2121 {"Flow target - Value":"27"}
> 01:43:45.586 1 2121 {"Flow target - Value":"28"}
> 01:43:46.310 1 2121 {"Pressure target - Value":"7"}
> 01:43:46.350 1 2121 {"Flow target - Value":"28"}
> 01:43:48.563 1 2121 {"Pressure target - Value":"7"}
> 01:43:48.567 1 2121 {"Flow target - Value":"28"}
> 01:43:51.850 1 2121 {"Pressure target - Value":"7"}
> 01:43:51.890 1 2121 {"Flow target - Value":"28"}
> 01:43:53.512 1 2121 {"Pressure target - Value":"7"}
> 01:43:53.516 1 2121 {"Flow target - Value":"28"}
> 01:43:56.108 1 2121 {"Pressure target - Value":"7"}
> 01:43:56.112 1 2121 {"Flow target - Value":"28"}
> 01:43:58.533 1 2121 {"Pressure target - Value":"7"}
> 01:43:58.538 1 2121 {"Flow target - Value":"28"}
> 01:44:01.600 1 2121 {"Pressure target - Value":"7"}
> 01:44:01.630 1 2121 {"Flow target - Value":"28"}
> 01:44:03.587 1 2121 {"Pressure target - Value":"7"}
> 01:44:03.591 1 2121 {"Flow target - Value":"28"}
> 01:44:06.180 1 2121 {"Pressure target - Value":"7"}
> 01:44:06.230 1 2121 {"Flow target - Value":"28"}
>
>
> Greetz Norman
>
>
>
> --
> View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-CEP-AbstractCEPPatternOperator-fail-after-event-detection-tp5948p5996.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
