Generated test files for migration/snapshot

pinterest · Dec 12, 2024 · bf362ae · bf362ae
1 parent 9f95a6b
commit bf362ae
Show file tree

Hide file tree

Showing 43 changed files with 6 additions and 4 deletions.
diff --git a/.../java/com/pinterest/flink/streaming/connectors/psc/FlinkPscConsumerBaseMigrationTest.java b/.../java/com/pinterest/flink/streaming/connectors/psc/FlinkPscConsumerBaseMigrationTest.java
@@ -117,7 +117,9 @@ public static Collection<FlinkVersion> parameters() {
                 FlinkVersion.v1_13,
                 FlinkVersion.v1_14,
                 FlinkVersion.v1_15,
-                FlinkVersion.v1_16
+                FlinkVersion.v1_16,
+                FlinkVersion.v1_17,
+                FlinkVersion.v1_18
         );
     }
 

diff --git a/...test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerMigrationTest.java b/...test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerMigrationTest.java
@@ -42,7 +42,7 @@
 public class FlinkPscProducerMigrationTest extends PscMigrationTestBase {
     @Parameterized.Parameters(name = "Migration Savepoint: {0}")
     public static Collection<FlinkVersion> parameters() {
-        return FlinkVersion.rangeOf(FlinkVersion.v1_11, FlinkVersion.v1_16);
+        return FlinkVersion.rangeOf(FlinkVersion.v1_11, FlinkVersion.v1_18);
     }
 
     public FlinkPscProducerMigrationTest(FlinkVersion testMigrateVersion) {

diff --git a/...link/src/test/java/com/pinterest/flink/streaming/connectors/psc/PscMigrationTestBase.java b/...link/src/test/java/com/pinterest/flink/streaming/connectors/psc/PscMigrationTestBase.java
@@ -59,7 +59,7 @@ public abstract class PscMigrationTestBase extends PscTestBaseWithKafkaAsPubSub
             new KeyedSerializationSchemaWrapper<>(integerSerializationSchema);
 
     /**
-     * Instructions: change this to the corresponding savepoint version to be written (e.g. {@link MigrationVersion#v1_3} for 1.3)
+     * Instructions: change this to the corresponding savepoint version to be written (e.g. {@link FlinkVersion#v1_3} for 1.3)
      * and remove all @Ignore annotations on writeSnapshot() methods to generate savepoints
      * Note: You should generate the savepoint based on the release branch instead of the master.
      */

diff --git a/...com/pinterest/flink/streaming/connectors/psc/testutils/TypeSerializerUpgradeTestBase.java b/...com/pinterest/flink/streaming/connectors/psc/testutils/TypeSerializerUpgradeTestBase.java
@@ -60,7 +60,7 @@
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
 public abstract class TypeSerializerUpgradeTestBase<PreviousElementT, UpgradedElementT> {
 
-    public static final FlinkVersion CURRENT_VERSION = FlinkVersion.v1_17;
+    public static final FlinkVersion CURRENT_VERSION = FlinkVersion.v1_18;
 
     public static final Set<FlinkVersion> MIGRATION_VERSIONS =
             FlinkVersion.rangeOf(FlinkVersion.v1_11, CURRENT_VERSION);

diff --git a/psc-flink/src/test/resources/context-state-serializer-1.11/serializer-snapshot b/psc-flink/src/test/resources/context-state-serializer-1.11/serializer-snapshot
diff --git a/psc-flink/src/test/resources/context-state-serializer-1.12/serializer-snapshot b/psc-flink/src/test/resources/context-state-serializer-1.12/serializer-snapshot
diff --git a/psc-flink/src/test/resources/context-state-serializer-1.12/test-data b/psc-flink/src/test/resources/context-state-serializer-1.12/test-data
diff --git a/psc-flink/src/test/resources/context-state-serializer-1.13/serializer-snapshot b/psc-flink/src/test/resources/context-state-serializer-1.13/serializer-snapshot
diff --git a/psc-flink/src/test/resources/context-state-serializer-1.13/test-data b/psc-flink/src/test/resources/context-state-serializer-1.13/test-data
diff --git a/psc-flink/src/test/resources/context-state-serializer-1.14/serializer-snapshot b/psc-flink/src/test/resources/context-state-serializer-1.14/serializer-snapshot
diff --git a/psc-flink/src/test/resources/context-state-serializer-1.14/test-data b/psc-flink/src/test/resources/context-state-serializer-1.14/test-data
diff --git a/psc-flink/src/test/resources/context-state-serializer-1.15/serializer-snapshot b/psc-flink/src/test/resources/context-state-serializer-1.15/serializer-snapshot
diff --git a/psc-flink/src/test/resources/context-state-serializer-1.15/test-data b/psc-flink/src/test/resources/context-state-serializer-1.15/test-data
diff --git a/psc-flink/src/test/resources/context-state-serializer-1.16/serializer-snapshot b/psc-flink/src/test/resources/context-state-serializer-1.16/serializer-snapshot
diff --git a/psc-flink/src/test/resources/context-state-serializer-1.16/test-data b/psc-flink/src/test/resources/context-state-serializer-1.16/test-data
diff --git a/psc-flink/src/test/resources/context-state-serializer-1.17/serializer-snapshot b/psc-flink/src/test/resources/context-state-serializer-1.17/serializer-snapshot
diff --git a/psc-flink/src/test/resources/context-state-serializer-1.17/test-data b/psc-flink/src/test/resources/context-state-serializer-1.17/test-data
diff --git a/psc-flink/src/test/resources/context-state-serializer-1.18/serializer-snapshot b/psc-flink/src/test/resources/context-state-serializer-1.18/serializer-snapshot
diff --git a/psc-flink/src/test/resources/context-state-serializer-1.18/test-data b/psc-flink/src/test/resources/context-state-serializer-1.18/test-data
diff --git a/psc-flink/src/test/resources/psc-consumer-migration-test-flink1.16-empty-state-snapshot b/psc-flink/src/test/resources/psc-consumer-migration-test-flink1.16-empty-state-snapshot
diff --git a/psc-flink/src/test/resources/psc-consumer-migration-test-flink1.16-snapshot b/psc-flink/src/test/resources/psc-consumer-migration-test-flink1.16-snapshot
diff --git a/psc-flink/src/test/resources/psc-consumer-migration-test-flink1.17-empty-state-snapshot b/psc-flink/src/test/resources/psc-consumer-migration-test-flink1.17-empty-state-snapshot
diff --git a/psc-flink/src/test/resources/psc-consumer-migration-test-flink1.17-snapshot b/psc-flink/src/test/resources/psc-consumer-migration-test-flink1.17-snapshot
diff --git a/psc-flink/src/test/resources/psc-consumer-migration-test-flink1.18-empty-state-snapshot b/psc-flink/src/test/resources/psc-consumer-migration-test-flink1.18-empty-state-snapshot
diff --git a/psc-flink/src/test/resources/psc-consumer-migration-test-flink1.18-snapshot b/psc-flink/src/test/resources/psc-consumer-migration-test-flink1.18-snapshot
diff --git a/psc-flink/src/test/resources/psc-migration-psc-producer-flink-1.16-snapshot b/psc-flink/src/test/resources/psc-migration-psc-producer-flink-1.16-snapshot
diff --git a/psc-flink/src/test/resources/psc-migration-psc-producer-flink-1.17-snapshot b/psc-flink/src/test/resources/psc-migration-psc-producer-flink-1.17-snapshot
diff --git a/psc-flink/src/test/resources/psc-migration-psc-producer-flink-1.18-snapshot b/psc-flink/src/test/resources/psc-migration-psc-producer-flink-1.18-snapshot
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.11/serializer-snapshot b/psc-flink/src/test/resources/transaction-state-serializer-1.11/serializer-snapshot
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.12/serializer-snapshot b/psc-flink/src/test/resources/transaction-state-serializer-1.12/serializer-snapshot
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.12/test-data b/psc-flink/src/test/resources/transaction-state-serializer-1.12/test-data
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.13/serializer-snapshot b/psc-flink/src/test/resources/transaction-state-serializer-1.13/serializer-snapshot
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.13/test-data b/psc-flink/src/test/resources/transaction-state-serializer-1.13/test-data
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.14/serializer-snapshot b/psc-flink/src/test/resources/transaction-state-serializer-1.14/serializer-snapshot
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.14/test-data b/psc-flink/src/test/resources/transaction-state-serializer-1.14/test-data
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.15/serializer-snapshot b/psc-flink/src/test/resources/transaction-state-serializer-1.15/serializer-snapshot
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.15/test-data b/psc-flink/src/test/resources/transaction-state-serializer-1.15/test-data
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.16/serializer-snapshot b/psc-flink/src/test/resources/transaction-state-serializer-1.16/serializer-snapshot
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.16/test-data b/psc-flink/src/test/resources/transaction-state-serializer-1.16/test-data
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.17/serializer-snapshot b/psc-flink/src/test/resources/transaction-state-serializer-1.17/serializer-snapshot
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.17/test-data b/psc-flink/src/test/resources/transaction-state-serializer-1.17/test-data
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.18/serializer-snapshot b/psc-flink/src/test/resources/transaction-state-serializer-1.18/serializer-snapshot
diff --git a/psc-flink/src/test/resources/transaction-state-serializer-1.18/test-data b/psc-flink/src/test/resources/transaction-state-serializer-1.18/test-data