This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 84530f4 [FLINK-26152] [docs] Translate the page of SQL/queries/WITH
clause (#18828)
new 0b9f895 [FLINK-26146] Add tests of flink version upgrades to cover
native snapshots
new 9dd6043 [FLINK-26176] Fix scala savepoint migration tests
new c88189f [FLINK-26146] Adapt scala tests to cover native snapshots
migration
The 3 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:
.../LegacyStatefulJobSavepointMigrationITCase.java | 8 +-
...ava => StatefulJobSnapshotMigrationITCase.java} | 145 ++++++------
.../StatefulJobWBroadcastStateMigrationITCase.java | 139 +++++++-----
.../checkpointing/utils/MigrationTestUtils.java | 4 +-
...estBase.java => SnapshotMigrationTestBase.java} | 191 ++++++++++++++--
.../TypeSerializerSnapshotMigrationITCase.java | 155 +++++++------
.../_metadata | Bin 41481 -> 0 bytes
.../_metadata | Bin 41584 -> 0 bytes
.../_metadata | Bin 41436 -> 0 bytes
.../_metadata | Bin 41962 -> 0 bytes
.../_metadata | Bin 42002 -> 0 bytes
.../_metadata | Bin 213759 -> 0 bytes
.../_metadata | Bin 213759 -> 0 bytes
.../_metadata | Bin 204543 -> 0 bytes
.../_metadata | Bin 204543 -> 0 bytes
.../_metadata | Bin 205638 -> 0 bytes
.../_metadata | Bin 205638 -> 0 bytes
.../_metadata | Bin 229848 -> 0 bytes
.../_metadata | Bin 229848 -> 0 bytes
.../_metadata | Bin 39985 -> 0 bytes
.../_metadata | Bin 40081 -> 0 bytes
.../_metadata | Bin 53342 -> 0 bytes
.../_metadata | Bin 53419 -> 0 bytes
.../_metadata | Bin 53271 -> 0 bytes
.../_metadata | Bin 53733 -> 0 bytes
.../_metadata | Bin 53773 -> 0 bytes
.../_metadata | Bin 220470 -> 0 bytes
.../_metadata | Bin 220470 -> 0 bytes
.../_metadata | Bin 253956 -> 0 bytes
.../_metadata | Bin 253956 -> 0 bytes
.../_metadata | Bin 287008 -> 0 bytes
.../_metadata | Bin 287008 -> 0 bytes
.../_metadata | Bin 51846 -> 0 bytes
.../_metadata | Bin 51942 -> 0 bytes
.../StatefulJobSavepointMigrationITCase.scala | 206 +++++++++--------
...StatefulJobWBroadcastStateMigrationITCase.scala | 251 ++++++++++-----------
pom.xml | 4 +-
37 files changed, 651 insertions(+), 452 deletions(-)
rename flink-tests/src/test/java/org/apache/flink/test/checkpointing/{utils =>
}/LegacyStatefulJobSavepointMigrationITCase.java (99%)
rename
flink-tests/src/test/java/org/apache/flink/test/checkpointing/{utils/StatefulJobSavepointMigrationITCase.java
=> StatefulJobSnapshotMigrationITCase.java} (76%)
rename flink-tests/src/test/java/org/apache/flink/test/checkpointing/{utils =>
}/StatefulJobWBroadcastStateMigrationITCase.java (80%)
rename
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/{SavepointMigrationTestBase.java
=> SnapshotMigrationTestBase.java} (54%)
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.10-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.12-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.14-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.3-jobmanager-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.3-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.4-jobmanager-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.4-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.6-jobmanager-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.7-jobmanager-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.7-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.8-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.9-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.10-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.12-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.14-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.5-jobmanager-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.5-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.6-jobmanager-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.7-jobmanager-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.7-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.8-rocksdb-savepoint/_metadata
delete mode 100644
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.9-rocksdb-savepoint/_metadata
