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 99604c6 [FLINK-18552][tests] Update migration tests of
StatefulJobWBroadcastStateMigrationITCase to cover migration till release-1.11
new 8039df6 [FLINK-18552][tests] Update migration tests of
FlinkKafkaProducer011MigrationTest to cover migration from 1.10
new 60e7c42 [FLINK-18552][tests] Update migration tests of
FlinkKafkaProducerMigrationOperatorTest to cover migration from 1.10
new 44a3735 [FLINK-18552][tests] Update migration tests of
FlinkKafkaProducerMigrationTest to cover migration from 1.10
new 310e725 [FLINK-18552][tests] Update migration tests of
StatefulJobSavepointMigrationITCase (Java version) to cover migration from 1.10
new bce96ba [FLINK-18552][tests] Update migration tests of
StatefulJobWBroadcastStateMigrationITCase (Java version) to cover migration
from 1.10
new 0236661 [FLINK-18552][tests] Update migration tests of
TypeSerializerSnapshotMigrationITCase cover migration from 1.10
new 460969a [FLINK-18552][tests] Update migration tests of
AbstractKeyedOperatorRestoreTestBase to cover migration from 1.10
new 8cfabbd [FLINK-18552][tests] Update migration tests of
AbstractNonKeyedOperatorRestoreTestBase to cover migration from 1.10
new 0cd46ff [FLINK-18552][tests] Update migration tests of
FlinkKinesisConsumerMigrationTest to cover migration from 1.10
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.10-snapshot | Bin 0 -> 2032 bytes
.../kafka/FlinkKafkaProducerMigrationOperatorTest.java | 3 ++-
.../kafka/FlinkKafkaProducerMigrationTest.java | 3 ++-
...ka-0.11-migration-kafka-producer-flink-1.10-snapshot | Bin 0 -> 2032 bytes
.../kafka-migration-kafka-producer-flink-1.10-snapshot | Bin 0 -> 1232 bytes
.../kinesis/FlinkKinesisConsumerMigrationTest.java | 3 ++-
...sis-consumer-migration-test-flink1.10-empty-snapshot | Bin 0 -> 2862 bytes
.../kinesis-consumer-migration-test-flink1.10-snapshot | Bin 0 -> 2930 bytes
.../utils/StatefulJobSavepointMigrationITCase.java | 4 +++-
.../StatefulJobWBroadcastStateMigrationITCase.java | 4 +++-
.../TypeSerializerSnapshotMigrationITCase.java | 4 +++-
.../keyed/AbstractKeyedOperatorRestoreTestBase.java | 3 ++-
.../AbstractNonKeyedOperatorRestoreTestBase.java | 3 ++-
.../_metadata | Bin 0 -> 13942 bytes
.../_metadata | Bin 0 -> 14070 bytes
.../_metadata | Bin 0 -> 17377 bytes
.../_metadata | Bin 0 -> 17241 bytes
.../operatorstate/complexKeyed-flink1.10/_metadata | Bin 0 -> 18066 bytes
.../operatorstate/nonKeyed-flink1.10/_metadata | Bin 0 -> 3740 bytes
.../_metadata | Bin 0 -> 1287 bytes
.../_metadata | Bin 0 -> 1257 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.10-snapshot
create mode 100644
flink-connectors/flink-connector-kafka/src/test/resources/kafka-0.11-migration-kafka-producer-flink-1.10-snapshot
create mode 100644
flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.10-snapshot
create mode 100644
flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.10-empty-snapshot
create mode 100644
flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.10-snapshot
create mode 100644
flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.10-rocksdb-savepoint/_metadata
create mode 100644
flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.10-savepoint/_metadata
create mode 100644
flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.10-rocksdb-savepoint/_metadata
create mode 100644
flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.10-savepoint/_metadata
create mode 100644
flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.10/_metadata
create mode 100644
flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.10/_metadata
create mode 100644
flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.10-rocksdb-savepoint/_metadata
create mode 100644
flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.10-savepoint/_metadata
