search

haoch / flink-siddhi

A CEP library to run Siddhi within Apache Flink™ Streaming Application (Not maintained)
Apache License 2.0
243 stars 96 forks source link

Dynamic CEP doesn't work on Flink 1.8.2 #69

Open ccbeloy opened 4 years ago

ccbeloy commented 4 years ago

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)