You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2020/07/24 15:12:09 UTC
[flink] branch release-1.11 updated (ce270cd -> 7cfd72d)
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git.
from ce270cd [FLINK-18697][table-api] Add the missing test scope to the flink-streaming-java_2.11:test-jar dependency
new e55516a [FLINK-18552][tests] Update migration tests of FlinkKafkaProducer011MigrationTest to cover migration from 1.11
new 5d46423 [FLINK-18552][tests] Update migration tests of FlinkKafkaProducerMigrationOperatorTest to cover migration from 1.11
new 6f83b75 [FLINK-18552][tests] Update migration tests of FlinkKafkaProducerMigrationTest to cover migration from 1.11
new f48e1cf [FLINK-18552][tests] Update migration tests of StatefulJobSavepointMigrationITCase (Java version) to cover migration from 1.11
new dbfde3e [FLINK-18552][tests] Update migration tests of StatefulJobWBroadcastStateMigrationITCase (Java version) to cover migration from 1.11
new e7a14a6 [FLINK-18552][tests] Update migration tests of TypeSerializerSnapshotMigrationITCase cover migration from 1.11
new 08a1ca9 [FLINK-18552][tests] Update migration tests of AbstractKeyedOperatorRestoreTestBase to cover migration from 1.11
new 3bd56dc [FLINK-18552][tests] Update migration tests of AbstractNonKeyedOperatorRestoreTestBase to cover migration from 1.11
new 7cfd72d [FLINK-18552][tests] Update migration tests of FlinkKinesisConsumerMigrationTest to cover migration from 1.11
The 9 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../kafka/FlinkKafkaProducer011MigrationTest.java | 3 ++-
.../kafka-migration-kafka-producer-flink-1.11-snapshot | Bin 0 -> 2040 bytes
.../kafka/FlinkKafkaProducerMigrationOperatorTest.java | 3 ++-
.../kafka/FlinkKafkaProducerMigrationTest.java | 3 ++-
...ka-0.11-migration-kafka-producer-flink-1.11-snapshot | Bin 0 -> 2040 bytes
.../kafka-migration-kafka-producer-flink-1.11-snapshot | Bin 0 -> 1240 bytes
.../kinesis/FlinkKinesisConsumerMigrationTest.java | 3 ++-
...sis-consumer-migration-test-flink1.11-empty-snapshot | Bin 0 -> 2870 bytes
.../kinesis-consumer-migration-test-flink1.11-snapshot | Bin 0 -> 2938 bytes
.../utils/StatefulJobSavepointMigrationITCase.java | 4 +++-
.../StatefulJobWBroadcastStateMigrationITCase.java | 4 +++-
.../TypeSerializerSnapshotMigrationITCase.java | 4 +++-
.../keyed/AbstractKeyedOperatorRestoreTestBase.java | 3 ++-
.../AbstractNonKeyedOperatorRestoreTestBase.java | 3 ++-
.../_metadata | Bin 0 -> 13838 bytes
.../_metadata | Bin 0 -> 13966 bytes
.../_metadata | Bin 0 -> 17257 bytes
.../_metadata | Bin 0 -> 17121 bytes
.../operatorstate/complexKeyed-flink1.11/_metadata | Bin 0 -> 18009 bytes
.../operatorstate/nonKeyed-flink1.11/_metadata | Bin 0 -> 3664 bytes
.../_metadata | Bin 0 -> 1266 bytes
.../_metadata | Bin 0 -> 1236 bytes
22 files changed, 21 insertions(+), 9 deletions(-)
create mode 100644 flink-connectors/flink-connector-kafka-0.11/src/test/resources/kafka-migration-kafka-producer-flink-1.11-snapshot
create mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-0.11-migration-kafka-producer-flink-1.11-snapshot
create mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.11-snapshot
create mode 100644 flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.11-empty-snapshot
create mode 100644 flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.11-snapshot
create mode 100644 flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metadata
create mode 100644 flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.11-savepoint/_metadata
create mode 100644 flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metadata
create mode 100644 flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.11-savepoint/_metadata
create mode 100644 flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.11/_metadata
create mode 100644 flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.11/_metadata
create mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.11-rocksdb-savepoint/_metadata
create mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.11-savepoint/_metadata
[flink] 09/09: [FLINK-18552][tests] Update migration tests of
FlinkKinesisConsumerMigrationTest to cover migration from 1.11
Posted by pn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 7cfd72d489e27049e1f82501c461f855b690f0c2
Author: Yun Gao <ga...@gmail.com>
AuthorDate: Thu Jul 23 23:14:57 2020 +0800
[FLINK-18552][tests] Update migration tests of FlinkKinesisConsumerMigrationTest to cover migration from 1.11
---
.../kinesis/FlinkKinesisConsumerMigrationTest.java | 3 ++-
...esis-consumer-migration-test-flink1.11-empty-snapshot | Bin 0 -> 2870 bytes
.../kinesis-consumer-migration-test-flink1.11-snapshot | Bin 0 -> 2938 bytes
3 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
index 6aa5956..0213587 100644
--- a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
+++ b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
@@ -102,7 +102,8 @@ public class FlinkKinesisConsumerMigrationTest {
MigrationVersion.v1_7,
MigrationVersion.v1_8,
MigrationVersion.v1_9,
- MigrationVersion.v1_10);
+ MigrationVersion.v1_10,
+ MigrationVersion.v1_11);
}
public FlinkKinesisConsumerMigrationTest(MigrationVersion testMigrateVersion) {
diff --git a/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.11-empty-snapshot b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.11-empty-snapshot
new file mode 100644
index 0000000..8c83f09
Binary files /dev/null and b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.11-empty-snapshot differ
diff --git a/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.11-snapshot b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.11-snapshot
new file mode 100644
index 0000000..a4bf97c
Binary files /dev/null and b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.11-snapshot differ
[flink] 03/09: [FLINK-18552][tests] Update migration tests of
FlinkKafkaProducerMigrationTest to cover migration from 1.11
Posted by pn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 6f83b75b3e678b4887f0825b378486893f88dc6f
Author: Yun Gao <ga...@gmail.com>
AuthorDate: Thu Jul 23 23:01:07 2020 +0800
[FLINK-18552][tests] Update migration tests of FlinkKafkaProducerMigrationTest to cover migration from 1.11
---
.../kafka/FlinkKafkaProducerMigrationTest.java | 3 ++-
.../kafka-migration-kafka-producer-flink-1.11-snapshot | Bin 0 -> 1240 bytes
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
index 0317396..78fd7bc 100644
--- a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
+++ b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
@@ -46,7 +46,8 @@ public class FlinkKafkaProducerMigrationTest extends KafkaMigrationTestBase {
return Arrays.asList(
MigrationVersion.v1_8,
MigrationVersion.v1_9,
- MigrationVersion.v1_10);
+ MigrationVersion.v1_10,
+ MigrationVersion.v1_11);
}
public FlinkKafkaProducerMigrationTest(MigrationVersion testMigrateVersion) {
diff --git a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.11-snapshot b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.11-snapshot
new file mode 100644
index 0000000..b4d285d
Binary files /dev/null and b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.11-snapshot differ
[flink] 02/09: [FLINK-18552][tests] Update migration tests of
FlinkKafkaProducerMigrationOperatorTest to cover migration from 1.11
Posted by pn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 5d464236808646e711d1aec0d8faf54182948af1
Author: Yun Gao <ga...@gmail.com>
AuthorDate: Thu Jul 23 22:57:57 2020 +0800
[FLINK-18552][tests] Update migration tests of FlinkKafkaProducerMigrationOperatorTest to cover migration from 1.11
---
.../kafka/FlinkKafkaProducerMigrationOperatorTest.java | 3 ++-
...fka-0.11-migration-kafka-producer-flink-1.11-snapshot | Bin 0 -> 2040 bytes
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationOperatorTest.java b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationOperatorTest.java
index 46247a6..e000b61 100644
--- a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationOperatorTest.java
+++ b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationOperatorTest.java
@@ -40,7 +40,8 @@ public class FlinkKafkaProducerMigrationOperatorTest extends FlinkKafkaProducerM
return Arrays.asList(
MigrationVersion.v1_8,
MigrationVersion.v1_9,
- MigrationVersion.v1_10);
+ MigrationVersion.v1_10,
+ MigrationVersion.v1_11);
}
public FlinkKafkaProducerMigrationOperatorTest(MigrationVersion testMigrateVersion) {
diff --git a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-0.11-migration-kafka-producer-flink-1.11-snapshot b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-0.11-migration-kafka-producer-flink-1.11-snapshot
new file mode 100644
index 0000000..f80a429
Binary files /dev/null and b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-0.11-migration-kafka-producer-flink-1.11-snapshot differ
[flink] 05/09: [FLINK-18552][tests] Update migration tests of
StatefulJobWBroadcastStateMigrationITCase (Java version) to cover migration
from 1.11
Posted by pn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit dbfde3e06500017ca8871f484f5b4f9fd47c119f
Author: Yun Gao <ga...@gmail.com>
AuthorDate: Thu Jul 23 23:04:17 2020 +0800
[FLINK-18552][tests] Update migration tests of StatefulJobWBroadcastStateMigrationITCase (Java version) to cover migration from 1.11
---
.../StatefulJobWBroadcastStateMigrationITCase.java | 4 +++-
.../_metadata | Bin 0 -> 13838 bytes
.../_metadata | Bin 0 -> 13966 bytes
3 files changed, 3 insertions(+), 1 deletion(-)
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java
index e85b2b1..9351005 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java
@@ -74,7 +74,9 @@ public class StatefulJobWBroadcastStateMigrationITCase extends SavepointMigratio
Tuple2.of(MigrationVersion.v1_9, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_9, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_10, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
- Tuple2.of(MigrationVersion.v1_10, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
+ Tuple2.of(MigrationVersion.v1_10, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
}
private final MigrationVersion testMigrateVersion;
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metadata b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metadata
new file mode 100644
index 0000000..a4e58b7
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.11-savepoint/_metadata b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.11-savepoint/_metadata
new file mode 100644
index 0000000..144fe72
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.11-savepoint/_metadata differ
[flink] 01/09: [FLINK-18552][tests] Update migration tests of
FlinkKafkaProducer011MigrationTest to cover migration from 1.11
Posted by pn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit e55516a04002fbd34b618ff08edce642c2314ac0
Author: Yun Gao <ga...@gmail.com>
AuthorDate: Thu Jul 23 22:56:17 2020 +0800
[FLINK-18552][tests] Update migration tests of FlinkKafkaProducer011MigrationTest to cover migration from 1.11
---
.../kafka/FlinkKafkaProducer011MigrationTest.java | 3 ++-
.../kafka-migration-kafka-producer-flink-1.11-snapshot | Bin 0 -> 2040 bytes
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011MigrationTest.java b/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011MigrationTest.java
index 2456a9a..01305de 100644
--- a/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011MigrationTest.java
+++ b/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011MigrationTest.java
@@ -46,7 +46,8 @@ public class FlinkKafkaProducer011MigrationTest extends KafkaMigrationTestBase {
return Arrays.asList(
MigrationVersion.v1_8,
MigrationVersion.v1_9,
- MigrationVersion.v1_10);
+ MigrationVersion.v1_10,
+ MigrationVersion.v1_11);
}
public FlinkKafkaProducer011MigrationTest(MigrationVersion testMigrateVersion) {
diff --git a/flink-connectors/flink-connector-kafka-0.11/src/test/resources/kafka-migration-kafka-producer-flink-1.11-snapshot b/flink-connectors/flink-connector-kafka-0.11/src/test/resources/kafka-migration-kafka-producer-flink-1.11-snapshot
new file mode 100644
index 0000000..f80a429
Binary files /dev/null and b/flink-connectors/flink-connector-kafka-0.11/src/test/resources/kafka-migration-kafka-producer-flink-1.11-snapshot differ
[flink] 04/09: [FLINK-18552][tests] Update migration tests of
StatefulJobSavepointMigrationITCase (Java version) to cover migration from
1.11
Posted by pn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit f48e1cfb71ef57ebc219ed9847d3c2d884939dbe
Author: Yun Gao <ga...@gmail.com>
AuthorDate: Thu Jul 23 23:02:44 2020 +0800
[FLINK-18552][tests] Update migration tests of StatefulJobSavepointMigrationITCase (Java version) to cover migration from 1.11
---
.../utils/StatefulJobSavepointMigrationITCase.java | 4 +++-
.../_metadata | Bin 0 -> 17257 bytes
.../_metadata | Bin 0 -> 17121 bytes
3 files changed, 3 insertions(+), 1 deletion(-)
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
index f82d8e3..241f800 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
@@ -91,7 +91,9 @@ public class StatefulJobSavepointMigrationITCase extends SavepointMigrationTestB
Tuple2.of(MigrationVersion.v1_9, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_9, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_10, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
- Tuple2.of(MigrationVersion.v1_10, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
+ Tuple2.of(MigrationVersion.v1_10, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
}
private final MigrationVersion testMigrateVersion;
diff --git a/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metadata b/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metadata
new file mode 100644
index 0000000..5923143
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.11-savepoint/_metadata b/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.11-savepoint/_metadata
new file mode 100644
index 0000000..110187c
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.11-savepoint/_metadata differ
[flink] 06/09: [FLINK-18552][tests] Update migration tests of
TypeSerializerSnapshotMigrationITCase cover migration from 1.11
Posted by pn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit e7a14a62ed6816080341831b3daa33934ec5bc1c
Author: Yun Gao <ga...@gmail.com>
AuthorDate: Thu Jul 23 23:05:30 2020 +0800
[FLINK-18552][tests] Update migration tests of TypeSerializerSnapshotMigrationITCase cover migration from 1.11
---
.../migration/TypeSerializerSnapshotMigrationITCase.java | 4 +++-
.../_metadata | Bin 0 -> 1266 bytes
.../_metadata | Bin 0 -> 1236 bytes
3 files changed, 3 insertions(+), 1 deletion(-)
diff --git a/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java b/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java
index 6cdb4e2..cc5aa4d 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java
@@ -94,7 +94,9 @@ public class TypeSerializerSnapshotMigrationITCase extends SavepointMigrationTes
Tuple2.of(MigrationVersion.v1_9, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_9, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_10, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
- Tuple2.of(MigrationVersion.v1_10, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
+ Tuple2.of(MigrationVersion.v1_10, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
}
private final MigrationVersion testMigrateVersion;
diff --git a/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.11-rocksdb-savepoint/_metadata b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.11-rocksdb-savepoint/_metadata
new file mode 100644
index 0000000..e74cbee
Binary files /dev/null and b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.11-rocksdb-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.11-savepoint/_metadata b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.11-savepoint/_metadata
new file mode 100644
index 0000000..8fe792c
Binary files /dev/null and b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.11-savepoint/_metadata differ
[flink] 08/09: [FLINK-18552][tests] Update migration tests of
AbstractNonKeyedOperatorRestoreTestBase to cover migration from 1.11
Posted by pn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3bd56dc7750e8a24f619e265347712a95c26161d
Author: Yun Gao <ga...@gmail.com>
AuthorDate: Thu Jul 23 23:10:14 2020 +0800
[FLINK-18552][tests] Update migration tests of AbstractNonKeyedOperatorRestoreTestBase to cover migration from 1.11
---
.../unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java | 3 ++-
.../resources/operatorstate/nonKeyed-flink1.11/_metadata | Bin 0 -> 3664 bytes
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java
index d891ee7..07051ad 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java
@@ -55,7 +55,8 @@ public abstract class AbstractNonKeyedOperatorRestoreTestBase extends AbstractOp
MigrationVersion.v1_7,
MigrationVersion.v1_8,
MigrationVersion.v1_9,
- MigrationVersion.v1_10);
+ MigrationVersion.v1_10,
+ MigrationVersion.v1_11);
}
protected AbstractNonKeyedOperatorRestoreTestBase(MigrationVersion migrationVersion) {
diff --git a/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.11/_metadata b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.11/_metadata
new file mode 100644
index 0000000..733e8c4
Binary files /dev/null and b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.11/_metadata differ
[flink] 07/09: [FLINK-18552][tests] Update migration tests of
AbstractKeyedOperatorRestoreTestBase to cover migration from 1.11
Posted by pn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 08a1ca98295c3b633c69fda8a4f385ca26877169
Author: Yun Gao <ga...@gmail.com>
AuthorDate: Thu Jul 23 23:10:02 2020 +0800
[FLINK-18552][tests] Update migration tests of AbstractKeyedOperatorRestoreTestBase to cover migration from 1.11
---
.../keyed/AbstractKeyedOperatorRestoreTestBase.java | 3 ++-
.../operatorstate/complexKeyed-flink1.11/_metadata | Bin 0 -> 18009 bytes
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java
index 03a6d15..abac2f3 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java
@@ -49,7 +49,8 @@ public abstract class AbstractKeyedOperatorRestoreTestBase extends AbstractOpera
MigrationVersion.v1_7,
MigrationVersion.v1_8,
MigrationVersion.v1_9,
- MigrationVersion.v1_10);
+ MigrationVersion.v1_10,
+ MigrationVersion.v1_11);
}
public AbstractKeyedOperatorRestoreTestBase(MigrationVersion migrationVersion) {
diff --git a/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.11/_metadata b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.11/_metadata
new file mode 100644
index 0000000..d70693e
Binary files /dev/null and b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.11/_metadata differ