Hello, looks like a bug ... when a PriorityQueue is made with initialCapacity zero (see PriorityQueue.java) an illegal argument exception is thrown
http://stackoverflow.com/questions/3609342/why-priorityqueue-in-java-cannot-have-initialcapacity-0 The fix would be trivial: https://github.com/apache/flink/blob/master/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractCEPPatternOperator.java#L129 : when numberPriorityQueueEntries equals zero, create the PriorityQueue with capacity 1 instead of 0. greetings, Frank On Sat, Sep 17, 2016 at 2:56 PM, jaxbihani <jagad...@helpshift.com> wrote: > Updated attachment containing exceptions stacktrace > <http://apache-flink-user-mailing-list-archive.2336050. > n4.nabble.com/file/n9048/stacktrace.stacktrace> > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Problem-with- > CEPPatternOperator-when-taskmanager-is-killed-tp9024p9048.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
