You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by vijayakumar palaniappan <vi...@gmail.com> on 2017/04/11 16:06:40 UTC
CEP timeout does not trigger under certain conditions
-TimeoutPattern does not trigger under certain conditions. Following are
the preconditions:
-Assume a pattern of Event A followed by Event B within 2 Seconds
-PeriodicWaterMarks every 1 second
-Assume follwoing events have arrived.
-Event A-1[time: 1 sec]
-Event B-1[time: 2 sec]
-Event A-2[time: 2 sec]
-Event A-3[time: 5 sec]
-WaterMark[time: 5 sec]
I would assume that after watermark arrival, Event A-1,B-1 detected. A-2
timed out. But A-2 timeout does not happen.
if i use a punctuated watermark and generate watermark for every event, it
seems to work as expected.
To me this seems to be a bug, is my understanding correct?
--
Thanks,
-Vijay
Re: CEP timeout does not trigger under certain conditions
Posted by Aljoscha Krettek <al...@apache.org>.
+Kostas + Dawid, could you please have a look at this? You are kind of the experts on this topic.
> On 11. Apr 2017, at 18:09, vijayakumarpl <vi...@gmail.com> wrote:
>
> This is with 1.2.0 version of Flink libraries
>
>
>
> --
> View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/CEP-timeout-does-not-trigger-under-certain-conditions-tp12584p12585.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
Re: CEP timeout does not trigger under certain conditions
Posted by vijayakumarpl <vi...@gmail.com>.
This is with 1.2.0 version of Flink libraries
--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/CEP-timeout-does-not-trigger-under-certain-conditions-tp12584p12585.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
Re: CEP timeout does not trigger under certain conditions
Posted by Kostas Kloudas <k....@data-artisans.com>.
I just realized that the conversation was not sent to the Mailing List, so I am resending it.
Kostas
> On Apr 11, 2017, at 7:30 PM, vijayakumar palaniappan <vi...@gmail.com> wrote:
>
> Sure Thanks
>
> On Tue, Apr 11, 2017 at 1:28 PM, Kostas Kloudas <k.kloudas@data-artisans.com <ma...@data-artisans.com>> wrote:
> You are correct! I did not read your message correctly. This seems like a bug. You are using the 1.2 version right?
>
> Could you open a Jira issue?
>
> Thanks,
> Kostas
>
> On Apr 11, 2017 09:06, "vijayakumar palaniappan" <vijayakumarpl@gmail.com <ma...@gmail.com>> wrote:
> -TimeoutPattern does not trigger under certain conditions. Following are the preconditions:
>
> -Assume a pattern of Event A followed by Event B within 2 Seconds
>
> -PeriodicWaterMarks every 1 second
>
> -Assume follwoing events have arrived.
>
> -Event A-1[time: 1 sec]
>
> -Event B-1[time: 2 sec]
>
> -Event A-2[time: 2 sec]
>
> -Event A-3[time: 5 sec]
>
> -WaterMark[time: 5 sec]
>
>
> I would assume that after watermark arrival, Event A-1,B-1 detected. A-2 timed out. But A-2 timeout does not happen.
>
> if i use a punctuated watermark and generate watermark for every event, it seems to work as expected.
>
> To me this seems to be a bug, is my understanding correct?
>
>
> --
> Thanks,
> -Vijay
>
>
>
> --
> Thanks,
> -Vijay