You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/05/23 09:16:04 UTC
[jira] [Closed] (FLINK-5753) CEP timeout handler.
[ https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kostas Kloudas closed FLINK-5753.
---------------------------------
Resolution: Cannot Reproduce
> CEP timeout handler.
> --------------------
>
> Key: FLINK-5753
> URL: https://issues.apache.org/jira/browse/FLINK-5753
> Project: Flink
> Issue Type: Bug
> Components: CEP
> Affects Versions: 1.1.2
> Reporter: MichaĆ Jurkiewicz
> Assignee: Kostas Kloudas
>
> I configured the following flink job in my environment:
> {code}
> Pattern<Event, ?> patternCommandStarted = Pattern.<Event> begin("event-accepted").subtype(Event.class)
> .where(e -> {event accepted where statement}).next("second-event-started").subtype(Event.class)
> .where(e -> {event started where statement}))
> .within(Time.seconds(30));
> DataStream<Either<Event, Event>> events = CEP
> .pattern(eventsStream.keyBy(e -> e.getEventProperties().get("deviceCode")), patternCommandStarted)
> .select(eventSelector, eventSelector);
> static class EventSelector implements PatternSelectFunction<Event, Event>, PatternTimeoutFunction<Event, Event> {}
> {code}
> The problem that I have is related to timeout handling. I observed that:
> if: first event appears, second event not appear in the stream
> and *no new events appear in a stream*, timeout handler is not executed.
> Expected result: timeout handler should be executed in case if there are no new events in a stream
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)