Details
-
Sub-task
-
Status: Closed
-
Blocker
-
Resolution: Fixed
-
None
Description
We should add an end-to-end test which verifies that we can upgrade Avro types by adding and removing fields. We can use the general purpose job (FLINK-8971) after it added Avro types for that.
What should happen is
- Start general purpose job
- Take savpoint
- Change Avro type to have different fields
- Resume from savepoint
Check for different state backends: RocksDB, FsStateBackend
Attachments
Issue Links
- links to