flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Daiqing Li <lidaiqing1...@gmail.com>
Subject Flink CEP issues
Date Tue, 08 Aug 2017 18:13:57 GMT
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

Mime
View raw message