Description
Job upgrades usually happen during the lifetime of a real world Flink job. Therefore, we should add an end-to-end test which exactly covers this scenario. I suggest to do the follwoing:
- run the general purpose testing job
FLINK-8971 - take a savepoint
- Modify the job by introducing a new operator and changing the order of others
- Resume the modified job from the savepoint
- Verify that everything went correctly
Attachments
Issue Links
- links to