Dynamic CEP doesn't work on Flink 1.8.2

[ccbeloy]

With AWS Kinesis Flink 1.8
Flink application built on flink 1.8.2 and flink-siddhi 0.2.2-SNAPSHOT or 0.2.1 both versions failed with below error:

messageType
INFO
threadName
flink-akka.actor.default-dispatcher-2
throwableInformation.0
java.lang.AbstractMethodError
throwableInformation.1
at org.apache.flink.runtime.io.network.api.writer.RecordWriter.emit(RecordWriter.java:128)
throwableInformation.2
at org.apache.flink.streaming.runtime.io.RecordWriterOutput.pushToRecordWriter(RecordWriterOutput.java:107)
throwableInformation.3
at org.apache.flink.streaming.runtime.io.RecordWriterOutput.collect(RecordWriterOutput.java:89)
throwableInformation.4
at org.apache.flink.streaming.runtime.io.RecordWriterOutput.collect(RecordWriterOutput.java:45)
throwableInformation.5
at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:718)
throwableInformation.6
at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:696)
throwableInformation.7
at org.apache.flink.streaming.siddhi.router.AddRouteOperator.processElement(AddRouteOperator.java:65)
throwableInformation.8
at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:202)
throwableInformation.9
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:105)
throwableInformation.10
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:308)
throwableInformation.11
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:714)
throwableInformation.12
at java.lang.Thread.run(Thread.java:748)