Hi Pedro,
each pattern gets translated into one or more Flink operators. Hence, your
Flink program becomes *very* large and requires much more time to be
deployed.
Hence, the timeout.
I'd try to limit the size your job by grouping your patterns and creating
an own job for each group.
You can also
Hello,
I'm using CEP to match a stream against around 1000 different patterns.
To do this I create de patterns and then iterate and call CEP.pattern() for
each. Later on, I merge the PatternStreams into one using
datastream.union().
The problem is that i'm getting this exception:
AstTimeoutExcep
