You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Daiqing Li <li...@gmail.com> on 2017/08/08 18:13:57 UTC
Flink CEP issues
Hi guys,
We are using flink cep to detect pattern. Here is the exception we got:
org.apache.flink.streaming.api.operators.InternalTimeServiceManager.
advanceWatermark(InternalTimeServiceManager.java:107)
at org.apache.flink.streaming.api.operators.AbstractStreamOperator.
processWatermark(AbstractStreamOperator.java:946)
at org.apache.flink.streaming.runtime.io.StreamInputProcessor$
ForwardingValveOutputHandler.handleWatermark(StreamInputProcessor.java:286)
... 7 more
Caused by: java.lang.IllegalStateException: Could not find id for entry:
SharedBufferEntry(ValueTimeWrapper(, 1502205437762, 0),
[SharedBufferEdge(null, 1)], 1)
at org.apache.flink.util.Preconditions.checkState(Preconditions.java:195)
at org.apache.flink.cep.nfa.SharedBuffer$SharedBufferSerializer.
serialize(SharedBuffer.java:971)
at org.apache.flink.cep.nfa.SharedBuffer$SharedBufferSerializer.
serialize(SharedBuffer.java:838)
at org.apache.flink.cep.nfa.NFA$NFASerializer.serialize(NFA.java:928)
at org.apache.flink.cep.nfa.NFA$NFASerializer.serialize(NFA.java:852)
at org.apache.flink.contrib.streaming.state.RocksDBValueState.update(
RocksDBValueState.java:99)
In our event class, I use UUID as hash code and implement equals method
properly. Anyone knows what is going on?
Best,
Daiqing
Re: Flink CEP issues
Posted by Kostas Kloudas <k....@data-artisans.com>.
Hi Daiqing,
Is it possible to share your job in order to reproduce the problem?
Or at least a minimal example. If you see from the JIRA, there is another
user in https://issues.apache.org/jira/browse/FLINK-6321 <https://issues.apache.org/jira/browse/FLINK-6321> who had
a similar problem but we never managed to reproduce it.
Thanks,
Kostas
> On Aug 8, 2017, at 8:13 PM, Daiqing Li <li...@gmail.com> wrote:
>
> Hi guys,
>
> We are using flink cep to detect pattern. Here is the exception we got:
>
> org.apache.flink.streaming.api.operators.InternalTimeServiceManager.advanceWatermark(InternalTimeServiceManager.java:107)
> at org.apache.flink.streaming.api.operators.AbstractStreamOperator.processWatermark(AbstractStreamOperator.java:946)
> at org.apache.flink.streaming.runtime.io <http://runtime.io/>.StreamInputProcessor$ForwardingValveOutputHandler.handleWatermark(StreamInputProcessor.java:286)
> ... 7 more
> Caused by: java.lang.IllegalStateException: Could not find id for entry: SharedBufferEntry(ValueTimeWrapper(, 1502205437762, 0), [SharedBufferEdge(null, 1)], 1)
> at org.apache.flink.util.Preconditions.checkState(Preconditions.java:195)
> at org.apache.flink.cep.nfa.SharedBuffer$SharedBufferSerializer.serialize(SharedBuffer.java:971)
> at org.apache.flink.cep.nfa.SharedBuffer$SharedBufferSerializer.serialize(SharedBuffer.java:838)
> at org.apache.flink.cep.nfa.NFA$NFASerializer.serialize(NFA.java:928)
> at org.apache.flink.cep.nfa.NFA$NFASerializer.serialize(NFA.java:852)
> at org.apache.flink.contrib.streaming.state.RocksDBValueState.update(RocksDBValueState.java:99)
>
> In our event class, I use UUID as hash code and implement equals method properly. Anyone knows what is going on?
>
> Best,
> Daiqing