[ https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16018367#comment-16018367 ]
Michał Jurkiewicz commented on FLINK-5753: ------------------------------------------ Hi [~kkl0u], Regarding the issue, situation is that this code is not in my project anymore. I passed message to my friend to check, no answer. Please close this issue for now. I see your point on getCurrentWatermark method, but this is the solution that works for me well. What you suggest to do in this case ? > 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)