[FLINK-10084] Migration tests weren't updated for 1.5

• Type: Improvement
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.6.0
• Fix Version/s: 1.6.1, 1.7.0
• Component/s: Tests
• Labels: pull-request-available
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 07/Aug/18 09:01
• Updated: 27/Apr/21 18:08
• Resolved: 14/Aug/18 08:07

Description

We have several tests to verify that state taken in previous versions can be properly restored in the current one.

Most of these tests were not updated to cover the migration from 1.5.

Below are all the migration tests I could find:

• AbstractOperatorRestoreTestBase
• CEPMigrationTest
• BucketingSinkMigrationTest
• FlinkKafkaConsumerBaseMigrationTest
• ContinuousFileProcessingMigrationTest
• WindowOperatorMigrationTest
• StatefulJobSavepointMigrationITCase
• StatefulJobWBroadcastStateMigrationITCase

Issue Links

• links to: GitHub Pull Request #6513

Sub-Tasks

• Update AbstractOperatorRestoreTestBase: Closed
• Update CEPMigrationTest: Closed
• Update BucketingSinkMigrationTest: Closed
• Update FlinkKafkaConsumerBaseMigrationTest: Closed
• Update ContinuousFileProcessingMigrationTest: Closed
• Update WindowOperatorMigrationTest: Closed
• Update StatefulJobSavepointMigrationITCase: Closed
• Update StatefulJobWBroadcastStateMigrationITCase: Closed