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
