Re: Flink CEP AbstractCEPPatternOperator fail after event detection

Posted by norman sp on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-CEP-AbstractCEPPatternOperator-fail-after-event-detection-tp5948p5976.html

Hi Till,
I used Flink version 1.0.0 and tried all three TimeCharacteristics.
Not I tried the new Flink 1.0.1 that gives me the following error.
After detecting an event it processes a few stream tuples but then crashes.
I'm not sure how to solve that part of the error message: "This can indicate that the element belonging to the previous relation has been already pruned, even though you expect it to be still there"

4>   #######   Warning! FlowPatternEvent:   #######
4> (7605e43c-ca20-4524-af5f-23fd8e55d7b9,Intensity - Value,25.0,3.0,75.0)
4> (5025ef64-2b83-4112-b9bd-2d7de46454c9,Pressure - Value,7.0,3.0,21.0)
4> (3d501c5b-b0e2-41e6-bfdc-14c996df6e19,Flow - Value,27.0,3.0,81.0)
04/06/2016 16:41:31 Map -> Sink: Unnamed(4/4) switched to CANCELED
04/06/2016 16:41:31 AbstractCEPPatternOperator(1/1) switched to FAILED
java.lang.RuntimeException: Failure happened in filter function.
        at org.apache.flink.cep.nfa.NFA.computeNextStates(NFA.java:292)
        at org.apache.flink.cep.nfa.NFA.process(NFA.java:136)
        at org.apache.flink.cep.operator.AbstractCEPPatternOperator.processEvent(AbstractCEPPatternOperator.java:93)
        at org.apache.flink.cep.operator.CEPPatternOperator.processWatermark(CEPPatternOperator.java:88)
        at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:158)
        at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65)
        at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:225)
        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
        at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalStateException: Could not find previous shared buffer entry with key: State(start, Normal, [
StateTransition(TAKE, FlowOver10, with filter),
StateTransition(IGNORE, start),
]), value: (83788338-b26c-4538-a437-77d1bbf7b348,Pressure - Value,7.0,5.0,35.0) and timestamp: 1459953675999. This can indicate that the element belonging to the previous relation has been already pruned, even though you expect it to be still there.
        at org.apache.flink.cep.nfa.SharedBuffer.put(SharedBuffer.java:104)
        at org.apache.flink.cep.nfa.NFA.computeNextStates(NFA.java:269)
        ... 8 more