Description
The following migration tests should be extended to cover migrating Flink jobs with a 1.4 savepoint.
- WindowOperatorMigrationTest
- CEPMigrationTest
- StatefulJobSavepointMigrationTestITCase
- FlinkKinesisConsumerMigrationTest
- FlinkKafkaConsumerBaseMigrationTest
- ContinuousFileProcessingMigrationTest
- BucketingSinkMigrationTest
Attachments
Issue Links
- links to