You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2021/02/18 11:51:20 UTC
[flink] 01/02: [FLINK-20534] Add Flink 1.12 MigrationVersion
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 2fb46aa54d8b95b1ca467eab0120e4279f1df2fa
Author: Dian Fu <di...@apache.org>
AuthorDate: Thu Feb 18 11:58:44 2021 +0800
[FLINK-20534] Add Flink 1.12 MigrationVersion
This closes #14956.
---
.../flink/api/common/typeutils/TypeSerializerUpgradeTestBase.java | 2 +-
.../java/org/apache/flink/testutils/migration/MigrationVersion.java | 3 ++-
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/TypeSerializerUpgradeTestBase.java b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/TypeSerializerUpgradeTestBase.java
index 168e457..ced0632 100644
--- a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/TypeSerializerUpgradeTestBase.java
+++ b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/TypeSerializerUpgradeTestBase.java
@@ -54,7 +54,7 @@ public abstract class TypeSerializerUpgradeTestBase<PreviousElementT, UpgradedEl
public static final MigrationVersion[] MIGRATION_VERSIONS =
MigrationVersion.v1_11.orHigher().toArray(new MigrationVersion[0]);
- public static final MigrationVersion CURRENT_VERSION = MigrationVersion.v1_11;
+ public static final MigrationVersion CURRENT_VERSION = MigrationVersion.v1_12;
private final TestSpecification<PreviousElementT, UpgradedElementT> testSpecification;
diff --git a/flink-core/src/test/java/org/apache/flink/testutils/migration/MigrationVersion.java b/flink-core/src/test/java/org/apache/flink/testutils/migration/MigrationVersion.java
index 214f07a..70322eb 100644
--- a/flink-core/src/test/java/org/apache/flink/testutils/migration/MigrationVersion.java
+++ b/flink-core/src/test/java/org/apache/flink/testutils/migration/MigrationVersion.java
@@ -43,7 +43,8 @@ public enum MigrationVersion {
v1_8("1.8"),
v1_9("1.9"),
v1_10("1.10"),
- v1_11("1.11");
+ v1_11("1.11"),
+ v1_12("1.12");
private final String versionStr;