Great to hear :-) I was already afraid that I've overlooked another window
boundary condition which I got wrong. If you should encounter other
problems, then let me know.
Cheers,
Till
On Fri, Sep 9, 2016 at 9:59 AM, Gyula Fóra <gyula.f...@gmail.com> wrote:
> 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.AbstractKeyedCEPPatternOperato
>>>>> r.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
>>>>>
>>>>>
>>>>>
>>>>
