Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
MIME-Version: 1.0
From: =?UTF-8?Q?Gyula_F=C3=B3ra?= <gyula.fora@gmail.com>
Date: Wed, 07 Sep 2016 14:43:47 +0000
Message-ID: <CA+faj9yM7Y74O1UpKV4iR91iUGBoQAGG0K+nP_HmvRXWZ-Wj-w@mail.gmail.com>
Subject: Exception in CEP 1.1.2
To: "user@flink.apache.org" <user@flink.apache.org>
Content-Type: multipart/alternative; boundary=001a114b1f0273c032053bebf1e6
archived-at: Wed, 07 Sep 2016 14:44:09 -0000

--001a114b1f0273c032053bebf1e6
Content-Type: text/plain; charset=UTF-8

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

--001a114b1f0273c032053bebf1e6
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr">Hi guys,<div><br></div><div>We tried building a simple pat=
tern with the CEP library that matches 2 events with 2 filter conditions (w=
here) but we get a strange error that comes from the stream operator:</div>=
<div><br></div><div><div><font color=3D"#333333">Pattern&lt;Either&lt;View,=
 Click&gt;, ?&gt; viewAndClick =3D Pattern</font></div><div><font color=3D"=
#333333">=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 .&lt;Eithe=
r&lt;View,, Click&gt;&gt; begin(&quot;view&quot;)</font></div><div><font co=
lor=3D"#333333">=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 .wh=
ere(Either::isLeft)</font></div><div><font color=3D"#333333">=C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 .followedBy(&quot;click&quot;).wh=
ere(Either::isRight)</font></div><div><font color=3D"#333333">=C2=A0 =C2=A0=
 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 .within(Time.hours(8));</font></=
div></div><div><font color=3D"#333333"><br></font></div><div><font color=3D=
"#333333">CEP.pattern(stream, pattern).select(...);<br></font></div><div><f=
ont color=3D"#333333"><br></font></div><div><font color=3D"#333333">We get =
the following exception when running this:</font></div><div><font color=3D"=
#333333"><div>java.lang.RuntimeException: Failure happened in filter functi=
on.</div><div>=E2=80=82=E2=80=82at org.apache.flink.cep.nfa.NFA.computeNext=
States(NFA.java:318)</div><div>=E2=80=82=E2=80=82at org.apache.flink.cep.nf=
a.NFA.process(NFA.java:162)</div><div>=E2=80=82=E2=80=82at org.apache.flink=
.cep.operator.KeyedCEPPatternOperator.processEvent(KeyedCEPPatternOperator.=
java:48)</div><div>=E2=80=82=E2=80=82at org.apache.flink.cep.operator.Abstr=
actCEPBasePatternOperator.processElement(AbstractCEPBasePatternOperator.jav=
a:72)</div><div>=E2=80=82=E2=80=82at org.apache.flink.cep.operator.Abstract=
KeyedCEPPatternOperator.processElement(AbstractKeyedCEPPatternOperator.java=
:161)</div><div>=E2=80=82=E2=80=82at org.apache.flink.streaming.runtime.io.=
StreamInputProcessor.processInput(StreamInputProcessor.java:176)</div><div>=
=E2=80=82=E2=80=82at org.apache.flink.streaming.runtime.tasks.OneInputStrea=
mTask.run(OneInputStreamTask.java:66)</div><div>=E2=80=82=E2=80=82at org.ap=
ache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:266)</=
div><div>=E2=80=82=E2=80=82at org.apache.flink.runtime.taskmanager.Task.run=
(Task.java:584)</div><div>=E2=80=82=E2=80=82at java.lang.Thread.run(Thread.=
java:745)</div><div>Caused by: java.lang.IllegalStateException: Could not f=
ind previous shared buffer entry with key: State(view, Normal, [</div><div>=
StateTransition(TAKE, click, with filter),</div><div>StateTransition(IGNORE=
, view),</div><div>]), 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.</div><div=
>=E2=80=82=E2=80=82at org.apache.flink.cep.nfa.SharedBuffer.put(SharedBuffe=
r.java:104)</div><div>=E2=80=82=E2=80=82at org.apache.flink.cep.nfa.NFA.com=
puteNextStates(NFA.java:295)</div><div>=E2=80=82=E2=80=82... 9 more</div><d=
iv><br></div><div>Any ideas on what&#39;s going on here?</div><div><br></di=
v><div>Thanks,</div><div>Gyula</div></font></div><div><font color=3D"#33333=
3"><br></font></div><div><font color=3D"#333333"><br></font></div></div>

--001a114b1f0273c032053bebf1e6--