Flink CEP issues

[Daiqing Li]

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

[Kostas Kloudas]

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 who had 

a similar problem but we never managed to reproduce it.

Thanks,

Kostas

On Aug 8, 2017, at 8:13 PM, Daiqing Li <[hidden email]> 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.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