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:11:30 UTC

[flink] branch master updated (a3b38c3 -> 740ffb5)

This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from a3b38c3  [FLINK-18697][table-api] Add the missing test scope to the flink-streaming-java_2.11:test-jar dependency
     add a49a350  [FLINK-18552][tests] Update migration tests of FlinkKafkaProducer011MigrationTest to cover migration from 1.11
     add 057f1b7  [FLINK-18552][tests] Update migration tests of FlinkKafkaProducerMigrationOperatorTest to cover migration from 1.11
     add f7e4d34  [FLINK-18552][tests] Update migration tests of FlinkKafkaProducerMigrationTest to cover migration from 1.11
     add 4aaada6  [FLINK-18552][tests] Update migration tests of StatefulJobSavepointMigrationITCase (Java version) to cover migration from 1.11
     add 6e0c53b  [FLINK-18552][tests] Update migration tests of StatefulJobWBroadcastStateMigrationITCase (Java version) to cover migration from 1.11
     add 0a842a7  [FLINK-18552][tests] Update migration tests of TypeSerializerSnapshotMigrationITCase cover migration from 1.11
     add a4d4481  [FLINK-18552][tests] Update migration tests of AbstractKeyedOperatorRestoreTestBase to cover migration from 1.11
     add c0ed23a  [FLINK-18552][tests] Update migration tests of AbstractNonKeyedOperatorRestoreTestBase to cover migration from 1.11
     add 740ffb5  [FLINK-18552][tests] Update migration tests of FlinkKinesisConsumerMigrationTest to cover migration from 1.11

No new revisions were added by this update.

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