flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Problem with CEPPatternOperator when taskmanager is killed
Date Mon, 19 Sep 2016 18:31:30 GMT
Thanks for looking into this Frank!

I opened FLINK-4636 [1] to track the issue.

Would you or Jaxbihani like to contribute a patch for this bug?

[1] https://issues.apache.org/jira/browse/FLINK-4636

2016-09-17 21:15 GMT+02:00 Frank Dekervel <kervel@gmail.com>:

> 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-maili
>> ng-list-archive.2336050.n4.nabble.com/Problem-with-CEPPat
>> ternOperator-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