CEP timeout does not trigger under certain conditions

[vijayakumarpl]

-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?

--

[vijayakumarpl]

This is with 1.2.0 version of Flink libraries

[Aljoscha Krettek]

+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 <[hidden email]> 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.

[Kostas Kloudas]

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 <[hidden email]> wrote:

Sure Thanks

On Tue, Apr 11, 2017 at 1:28 PM, Kostas Kloudas <[hidden email]> 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" <[hidden email]> 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?

--

--