Major Description
Currently the AbstractStreamOperatorTestHarness allows for testing an
operator when scaling up, through snapshot and restore. This is not enough
as many interesting corner cases arise when scaling down or during
arbitrary combinations of scaling up and down.
This issue targets to add this functionality so that an operator can snapshot
its state, restore with different parallelism, and later scale down or further up.
Attachments
Issue Links
- links to
