Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-13613

Update state migration tests for Flink 1.9

    XMLWordPrintableJSON

    Details

    • Type: Task
    • Status: Closed
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: 1.10.0
    • Fix Version/s: 1.10.0
    • Component/s: Tests
    • Labels:
      None

      Description

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

        Attachments

          Issue Links

          1.
          Add MigrationVersion.v1_9 Sub-task Closed vinoyang
          2.
          Update CEPMigrationTest to restore from 1.9 savepoint Sub-task Resolved vinoyang
          3.
          Update BucketingSinkMigrationTest to restore from 1.9 savepoint Sub-task Resolved vinoyang
          4.
          Update FlinkKafkaProducer011MigrationTest to restore from 1.9 savepoint Sub-task Resolved vinoyang
          5.
          Update FlinkKafkaConsumerBaseMigrationTest to restore from 1.9 savepoint Sub-task Resolved vinoyang
          6.
          Update FlinkKafkaProducerMigrationOperatorTest to restore from 1.9 savepoint Sub-task Closed vinoyang
          7.
          Update FlinkKafkaProducerMigrationTest to restore from 1.9 savepoint Sub-task Closed vinoyang
          8.
          Update ContinuousFileProcessingMigrationTest to restore from 1.9 savepoint Sub-task Closed vinoyang
          9.
          Update WindowOperatorMigrationTest to restore from 1.9 savepoint Sub-task Closed vinoyang
          10.
          Update StatefulJobSavepointMigrationITCase.scala to restore from 1.9 savepoint Sub-task Closed vinoyang
          11.
          Update StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint Sub-task Closed vinoyang
          12.
          Update StatefulJobWBroadcastStateMigrationITCase.scala to restore from 1.9 savepoint Sub-task Closed vinoyang
          13.
          Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint Sub-task Closed vinoyang
          14.
          Update TypeSerializerSnapshotMigrationITCase to restore from 1.9 savepoint Sub-task Closed vinoyang
          15.
          Update AbstractKeyedOperatorRestoreTestBase to restore from 1.9 savepoint Sub-task Closed vinoyang
          16.
          Update AbstractNonKeyedOperatorRestoreTestBase to restore from 1.9 savepoint Sub-task Closed vinoyang
          17.
          Update FlinkKinesisConsumerMigrationTest to restore from 1.9 savepoint Sub-task Closed vinoyang

            Activity

              People

              • Assignee:
                aljoscha Aljoscha Krettek
                Reporter:
                trohrmann Till Rohrmann
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 5h 40m
                  5h 40m