Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
We should update the following tests to cover migration from release-1.11:
- CEPMigrationTest
- BucketingSinkMigrationTest
- FlinkKafkaConsumerBaseMigrationTest
- ContinuousFileProcessingMigrationTest
- WindowOperatorMigrationTest
- StatefulJobSavepointMigrationITCase.scala
- StatefulJobWBroadcastStateMigrationITCase.scala
Refers to https://issues.apache.org/jira/browse/FLINK-13613, there are more migration tests requires to update:
- FlinkKafkaProducer011MigrationTest
- FlinkKafkaProducerMigrationOperatorTest
- FlinkKafkaProducerMigrationTest
- StatefulJobSavepointMigrationITCase
- StatefulJobWBroadcastStateMigrationITCase
- TypeSerializerSnapshotMigrationITCase
- AbstractKeyedOperatorRestoreTestBase
- AbstractNonKeyedOperatorRestoreTestBase
- FlinkKinesisConsumerMigrationTest
Attachments
Issue Links
- is duplicated by
-
FLINK-15707 Update state migration tests for Flink 1.10
- Closed
- links to
(2 links to)