Hi Norman, this error is exactly what I thought I had fixed. I guess there is still another case where a premature pruning can happen in the SharedBuffer. Could you maybe send me the example code with which you could produce the error. The input data would also be very helpful. Then I can debug it. Thanks :-)
Cheers, Till On Thu, Apr 7, 2016 at 7:50 AM, norman sp <wir12...@studserv.uni-leipzig.de> wrote: > 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 > > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-CEP-AbstractCEPPatternOperator-fail-after-event-detection-tp5948p5976.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
