How do I update parallelism of savepointed job
We have multiple DataStream Window operators with different parallelisms. Now we are facing a situation where we unable to introduce new DataStream due to parallelism mismatch problem. I have tried searching for Examples on how to use the State Processor APIs but couldn’t find any.
PS: We are using CEP library as well if that matters in this case.
Get access to unmatching events in Apache Flink Cep
I have a Flink Job with CEP pattern.