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.
I looked into StateProcessor API, but that works with execution type Batch only. We are not using that, so I am clueless on how do I make the saved job compatible with the changed parallelism.
New contributor
Shamsul Haque is a new contributor to this site. Take care in asking for clarification, commenting, and answering.
Check out our Code of Conduct.