Skip to content
Permalink
Browse files
[release] Upgrade current version to 1.15 for StatefulJobSavepointMig…
…rationITCase and create snapshots
  • Loading branch information
gaoyunhaii committed May 8, 2022
1 parent 609be42 commit 6e004ce76c816c446ec22b8a6ee685d5ff40ba3e
Show file tree
Hide file tree
Showing 38 changed files with 1 addition and 1 deletion.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
@@ -52,7 +52,7 @@ import scala.util.{Failure, Try}
object StatefulJobSavepointMigrationITCase {

// TODO increase this to newer version to create and test snapshot migration for newer versions
val currentVersion = FlinkVersion.v1_14
val currentVersion = FlinkVersion.v1_15

// TODO change this to CREATE_SNAPSHOT to (re)create binary snapshots
// TODO Note: You should generate the snapshot based on the release branch instead of the

0 comments on commit 6e004ce

Please sign in to comment.