[FLINK-15707] Update state migration tests for Flink 1.10

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.11.0
• Component/s: Tests
• Assignee: Unassigned
• Reporter: vinoyang
• Created: 21/Jan/20 09:40
• Updated: 27/Apr/21 18:07
• Resolved: 23/Apr/21 08:35

Description

Once the Flink 1.10.0 release is out, we should update existing migration tests to cover restoring from 1.10.0 savepoints.

Issue Links

• duplicates: FLINK-18552 Update migration tests in master to cover migration from release-1.11

Sub-Tasks

• Add MigrationVersion.v1_10: Closed
• Update CEPMigrationTest to restore from 1.10 savepoint: Closed
• Update BucketingSinkMigrationTest to restore from 1.10 savepoint: Closed
• Update FlinkKafkaProducer011MigrationTest to restore from 1.10 savepoint: Closed
• Update FlinkKafkaConsumerBaseMigrationTest to restore from 1.10 savepoint: Closed
• Update FlinkKafkaProducerMigrationOperatorTest to restore from 1.10 savepoint: Closed
• Update FlinkKafkaProducerMigrationTest to restore from 1.10 savepoint: Closed
• Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint: Closed
• Update WindowOperatorMigrationTest to restore from 1.10 savepoint: Closed
• Update StatefulJobSavepointMigrationITCase.scala to restore from 1.10 savepoint: Closed
• Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint: Closed
• Update StatefulJobWBroadcastStateMigrationITCase.scala to restore from 1.10 savepoint: Closed
• Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.10 savepoint: Closed
• Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint: Closed
• Update AbstractKeyedOperatorRestoreTestBase to restore from 1.10 savepoint: Closed
• Update AbstractNonKeyedOperatorRestoreTestBase to restore from 1.10 savepoint: Closed
• Update FlinkKinesisConsumerMigrationTest to restore from 1.10 savepoint: Closed