[FLINK-13613] Update state migration tests for Flink 1.9

• Type: Improvement
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Fix Version/s: 1.10.0
• Component/s: Tests
• Assignee: Aljoscha Krettek
• Reporter: Till Rohrmann
• Created: 07/Aug/19 09:42
• Updated: 27/Apr/21 18:07
• Resolved: 17/Jan/20 15:02

Description

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

Issue Links

• relates to: FLINK-13632 Port serializer upgrade tests to TypeSerializerUpgradeTestBase

Sub-Tasks

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