flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Frank Dekervel <ker...@gmail.com>
Subject Re: Problem with CEPPatternOperator when taskmanager is killed
Date Sat, 17 Sep 2016 19:15:04 GMT
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 <jagadish@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.
>

Mime
View raw message