Hi,
So we cant seem to be able to reproduce the error after clearing the local
maven cache.
It works now :)
Gyula
Gyula Fóra <gyula.f...@gmail.com> ezt írta (időpont: 2016. szept. 7., Sze,
22:05):
> Interestingly on my local machine I could not reproduce the problem, maybe
> it was some build issue on the other machine.
>
> Have to investigate tomorrow :)
>
> Gyula
>
> Gyula Fóra <gyula.f...@gmail.com> ezt írta (időpont: 2016. szept. 7.,
> Sze, 17:37):
>
>> Hi,
>>
>> I will try to get some minimal input to reproduce this. We were reading
>> events from Kafka so I might need some time.
>>
>> Thanks Till for looking into this
>>
>> Gyula
>>
>> Till Rohrmann <trohrm...@apache.org> ezt írta (időpont: 2016. szept. 7.,
>> Sze, 17:34):
>>
>>> Hi Gyula,
>>>
>>> could you send us en example input which reproduces the problem?
>>>
>>> The underlying problem is that the system expects a state to be still
>>> stored in the `SharedBuffer` which has already been removed. This should
>>> actually not happen and it clearly indicates a bug.
>>>
>>> Cheers,
>>> Till
>>>
>>> On Wed, Sep 7, 2016 at 4:43 PM, Gyula Fóra <gyula.f...@gmail.com> wrote:
>>>
>>>> Hi guys,
>>>>
>>>> We tried building a simple pattern with the CEP library that matches 2
>>>> events with 2 filter conditions (where) but we get a strange error that
>>>> comes from the stream operator:
>>>>
>>>> Pattern<Either<View, Click>, ?> viewAndClick = Pattern
>>>> .<Either<View,, Click>> begin("view")
>>>> .where(Either::isLeft)
>>>> .followedBy("click").where(Either::isRight)
>>>> .within(Time.hours(8));
>>>>
>>>> CEP.pattern(stream, pattern).select(...);
>>>>
>>>> We get the following exception when running this:
>>>> java.lang.RuntimeException: Failure happened in filter function.
>>>> at org.apache.flink.cep.nfa.NFA.computeNextStates(NFA.java:318)
>>>> at org.apache.flink.cep.nfa.NFA.process(NFA.java:162)
>>>> at
>>>> org.apache.flink.cep.operator.KeyedCEPPatternOperator.processEvent(KeyedCEPPatternOperator.java:48)
>>>> at
>>>> org.apache.flink.cep.operator.AbstractCEPBasePatternOperator.processElement(AbstractCEPBasePatternOperator.java:72)
>>>> at
>>>> org.apache.flink.cep.operator.AbstractKeyedCEPPatternOperator.processElement(AbstractKeyedCEPPatternOperator.java:161)
>>>> at org.apache.flink.streaming.runtime.io
>>>> .StreamInputProcessor.processInput(StreamInputProcessor.java:176)
>>>> at
>>>> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:66)
>>>> at
>>>> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:266)
>>>> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:584)
>>>> at java.lang.Thread.run(Thread.java:745)
>>>> Caused by: java.lang.IllegalStateException: Could not find previous
>>>> shared buffer entry with key: State(view, Normal, [
>>>> StateTransition(TAKE, click, with filter),
>>>> StateTransition(IGNORE, view),
>>>> ]), value: Left(View[...]) and timestamp: 1473258371116. 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:295)
>>>> ... 9 more
>>>>
>>>> Any ideas on what's going on here?
>>>>
>>>> Thanks,
>>>> Gyula
>>>>
>>>>
>>>>
>>>
