[FLINK-11197][tests] Improve migration test comments about how to gen…

…erate snapshots

flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkMigrationTest.java

@@ -69,6 +69,7 @@ public class BucketingSinkMigrationTest {
  /**
  * TODO change this to the corresponding savepoint version to be written (e.g. {@link MigrationVersion#v1_3} for 1.3)
  * TODO and remove all @Ignore annotations on write*Snapshot() methods to generate savepoints
+ * TODO Note: You should generate the savepoint based on the release branch instead of the master.
  */
  private final MigrationVersion flinkGenerateSavepointVersion = null;
 

flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java

@@ -79,6 +79,7 @@ public class FlinkKafkaConsumerBaseMigrationTest {
  /**
  * TODO change this to the corresponding savepoint version to be written (e.g. {@link MigrationVersion#v1_3} for 1.3)
  * TODO and remove all @Ignore annotations on write*Snapshot() methods to generate savepoints
+ * TODO Note: You should generate the savepoint based on the release branch instead of the master.
  */
  private final MigrationVersion flinkGenerateSavepointVersion = null;
 

flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java

@@ -76,6 +76,7 @@ public class FlinkKinesisConsumerMigrationTest {
  /**
  * TODO change this to the corresponding savepoint version to be written (e.g. {@link MigrationVersion#v1_3} for 1.3)
  * TODO and remove all @Ignore annotations on the writeSnapshot() method to generate savepoints
+ * TODO Note: You should generate the savepoint based on the release branch instead of the master.
  */
  private final MigrationVersion flinkGenerateSavepointVersion = null;
 

flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java

@@ -87,6 +87,7 @@ public static Collection<Tuple2<MigrationVersion, Long>> parameters () {
  /**
  * TODO change this to the corresponding savepoint version to be written (e.g. {@link MigrationVersion#v1_3} for 1.3)
  * TODO and remove all @Ignore annotations on write*Snapshot() methods to generate savepoints
+ * TODO Note: You should generate the savepoint based on the release branch instead of the master.
  */
  private final MigrationVersion flinkGenerateSavepointVersion = null;
 

flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPMigrationTest.java

@@ -64,6 +64,7 @@ public class CEPMigrationTest {
  /**
  * TODO change this to the corresponding savepoint version to be written (e.g. {@link MigrationVersion#v1_3} for 1.3)
  * TODO and remove all @Ignore annotations on write*Snapshot() methods to generate savepoints
+ * TODO Note: You should generate the savepoint based on the release branch instead of the master.
  */
  private final MigrationVersion flinkGenerateSavepointVersion = null;
 

flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java

@@ -100,6 +100,7 @@ public static Collection<MigrationVersion> parameters () {
  /**
  * TODO change this to the corresponding savepoint version to be written (e.g. {@link MigrationVersion#v1_3} for 1.3)
  * TODO and remove all @Ignore annotations on write*Snapshot() methods to generate savepoints
+ * TODO Note: You should generate the savepoint based on the release branch instead of the master.
  */
  private final MigrationVersion flinkGenerateSavepointVersion = null;
 

flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/LegacyStatefulJobSavepointMigrationITCase.java

@@ -82,6 +82,7 @@ public static Collection<Tuple2<MigrationVersion, String>> parameters () {
  * TODO to generate savepoints for a specific Flink version / backend type,
  * TODO change these values accordingly, e.g. to generate for 1.3 with RocksDB,
  * TODO set as (MigrationVersion.v1_3, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME)
+ * TODO Note: You should generate the savepoint based on the release branch instead of the master.
  */
  private final MigrationVersion flinkGenerateSavepointVersion = MigrationVersion.v1_4;
  private final String flinkGenerateSavepointBackendType = StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME;

flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java

@@ -72,6 +72,7 @@ public enum ExecutionMode {
  }
 
  // TODO change this to PERFORM_SAVEPOINT to regenerate binary savepoints
+ // TODO Note: You should generate the savepoint based on the release branch instead of the master.
  private final ExecutionMode executionMode = ExecutionMode.VERIFY_SAVEPOINT;
 
  @Parameterized.Parameters(name = "Migrate Savepoint / Backend: {0}")

flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java

@@ -56,6 +56,7 @@ public class StatefulJobWBroadcastStateMigrationITCase extends SavepointMigratio
  private static final int NUM_SOURCE_ELEMENTS = 4;
 
  // TODO change this to PERFORM_SAVEPOINT to regenerate binary savepoints
+ // TODO Note: You should generate the savepoint based on the release branch instead of the master.
  private final StatefulJobSavepointMigrationITCase.ExecutionMode executionMode =
  StatefulJobSavepointMigrationITCase.ExecutionMode.VERIFY_SAVEPOINT;
 

flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java

@@ -73,6 +73,7 @@ public enum ExecutionMode {
  }
 
  // TODO change this to PERFORM_SAVEPOINT to regenerate binary savepoints
+ // TODO Note: You should generate the savepoint based on the release branch instead of the master.
  private final ExecutionMode executionMode = ExecutionMode.VERIFY_SAVEPOINT;
 
  @Parameterized.Parameters(name = "Migrate Savepoint / Backend: {0}")

flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala

@@ -66,6 +66,7 @@ object StatefulJobSavepointMigrationITCase {
  // TODO to generate savepoints for a specific Flink version / backend type,
  // TODO change these values accordingly, e.g. to generate for 1.3 with RocksDB,
  // TODO set as (MigrationVersion.v1_3, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME)
+ // TODO Note: You should generate the savepoint based on the release branch instead of the master.
  val GENERATE_SAVEPOINT_VER: MigrationVersion = MigrationVersion.v1_4
  val GENERATE_SAVEPOINT_BACKEND_TYPE: String = StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME
 

flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala

@@ -64,6 +64,7 @@ object StatefulJobWBroadcastStateMigrationITCase {
  // TODO to generate savepoints for a specific Flink version / backend type,
  // TODO change these values accordingly, e.g. to generate for 1.3 with RocksDB,
  // TODO set as (MigrationVersion.v1_3, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME)
+ // TODO Note: You should generate the savepoint based on the release branch instead of the master.
  val GENERATE_SAVEPOINT_VER: MigrationVersion = MigrationVersion.v1_7
  val GENERATE_SAVEPOINT_BACKEND_TYPE: String = StateBackendLoader.MEMORY_STATE_BACKEND_NAME