Hi, You will need to use keyBy operation first to get all the events you need monitored in a pattern on the same node. Only then can you apply Pattern because it depends on the order of the events (first, next, followed by). I even had to make sure that the events were correctly sorted by timestamps to ensure that the first,next and followed by works correctly.
Sameer On Tue, Aug 9, 2016 at 12:17 PM, M Singh <mans2si...@yahoo.com> wrote: > Hey Folks: > > I have a question about CEP processing in Flink - How does flink > processing work when we have multiple partitions in which the events used > in the pattern sequence might be scattered across multiple partitions on > multiple nodes ? > > Thanks for your insight. > > Mans >
