Re: Problem with CEPPatternOperator when taskmanager is killed

Fabian Had a discussion with Frank. As he has no means to reproduce/test the bug I will submit a patch for this. -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Problem-with-CEPPatternOperator-when-taskmanager-is-killed-tp9024p9097.html Sent

Re: Problem with CEPPatternOperator when taskmanager is killed

@Frank : Thanks. I verified changing that and it works fine. (I still need to copy the user jar to the lib dir which ideally shouldn't be required but I think that is because of userCodeClassLoader() related problem. Will look into that) About implementation I feel instead of initializing priorit

Re: Problem with CEPPatternOperator when taskmanager is killed

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 : > Hello, > > looks like a bug ... when a PriorityQueu

Re: Problem with CEPPatternOperator when taskmanager is killed

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/apa

Re: Problem with CEPPatternOperator when taskmanager is killed

Updated attachment containing exceptions stacktrace -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Problem-with-CEPPatternOperator-whe