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 <lidaiqing1...@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
