Re: more complex patterns for CEP - Negation (was: CEP two transitions to the same state)

Hi, We are also looking for negation (absence of an event) functionality in Flink CEP. Something like notFollowedBy/notNext that detects the following patterns will be great additions to Flink CEP (other CEP frameworks support negation):1. Occurrence of an event (that matches specific criteria

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: Simple batch job hangs if run twice

Hi Aljoscha, Thanks for your response. By the first time I mean I hit run from the IDE (I am using Netbeans on Windows) the first time after building the program. If then I stop it and run it again (without rebuidling) It is stuck in the state RUNNING. Sometimes I have to rebuild it, or close the

Re: Simple batch job hangs if run twice

Hi, when is the "first time". It seems you have tried this repeatedly so what differentiates a "first time" from the other times? Are you closing your IDE in-between or do you mean running the job a second time within the same program? Cheers, Aljoscha On Fri, 9 Sep 2016 at 16:40 Yassine MARZOUGU

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

Re: Fw: Flink Cluster Load Distribution Question

One observation here is that you're only reading from one file. This will mean that you won't get any parallelism. Everything is executed on just one task/thread. Cheers, Aljoscha On Thu, 15 Sep 2016 at 01:24 amir bahmanyari wrote: > Hi Aljoscha, > Experimenting on relatively smaller file , ev