[jira] [Created] (FLINK-5753) CEP timeout handler.

["Michał Jurkiewicz (JIRA)" <ji...@apache.org>]

Michał Jurkiewicz created FLINK-5753:
----------------------------------------

             Summary: 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


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)