[flink] branch master updated (68d83ef -> 0fbea46)

[zh...@apache.org]

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

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


    from 68d83ef  [FLINK-18539][datastream] Fix StreamExecutionEnvironment#addSource(SourceFunction, TypeInformation) doesn't use the user defined type information
     add a1edfaf  [FLINK-18552][tests] Update migration tests of CEPMigrationTest to cover migration till release-1.11
     add 144c785  [FLINK-18552][tests] Update migration tests of BucketingSinkMigrationTest to cover migration till release-1.11
     add 5cd8423  [FLINK-18552][tests] Update migration tests of FlinkKafkaConsumerBaseMigrationTest to cover migration till release-1.11
     add e2a7902  [FLINK-18552][tests] Update migration tests of ContinuousFileProcessingMigrationTest to cover migration till release-1.11
     add 08e2049  [FLINK-18552][tests] Update migration tests of WindowOperatorMigrationTest to cover migration till release-1.11
     add bcbeedf  [FLINK-18552][tests] Update migration tests of StatefulJobSavepointMigrationITCase to cover migration till release-1.11
     add 0fbea46  [FLINK-18552][tests] Update migration tests of StatefulJobWBroadcastStateMigrationITCase to cover migration till release-1.11

No new revisions were added by this update.

Summary of changes:
 .../fs/bucketing/BucketingSinkMigrationTest.java        |   4 +++-
 .../bucketing-sink-migration-test-flink1.10-snapshot    | Bin 0 -> 1658 bytes
 .../bucketing-sink-migration-test-flink1.11-snapshot    | Bin 0 -> 1684 bytes
 .../kafka/FlinkKafkaConsumerBaseMigrationTest.java      |   4 +++-
 ...nsumer-migration-test-flink1.10-empty-state-snapshot | Bin 0 -> 1330 bytes
 .../kafka-consumer-migration-test-flink1.10-snapshot    | Bin 0 -> 1384 bytes
 ...nsumer-migration-test-flink1.11-empty-state-snapshot | Bin 0 -> 1151 bytes
 .../kafka-consumer-migration-test-flink1.11-snapshot    | Bin 0 -> 1205 bytes
 .../ContinuousFileProcessingMigrationTest.java          |   4 +++-
 ...tion-migration-test-1594559333000-flink1.10-snapshot | Bin 0 -> 316 bytes
 ...tion-migration-test-1594561663000-flink1.11-snapshot | Bin 0 -> 324 bytes
 .../resources/reader-migration-test-flink1.10-snapshot  | Bin 0 -> 2614 bytes
 .../resources/reader-migration-test-flink1.11-snapshot  | Bin 0 -> 2622 bytes
 .../org/apache/flink/cep/operator/CEPMigrationTest.java |   4 +++-
 .../cep-migration-after-branching-flink1.10-snapshot    | Bin 0 -> 7462 bytes
 .../cep-migration-after-branching-flink1.11-snapshot    | Bin 0 -> 7470 bytes
 .../cep-migration-conditions-flink1.10-snapshot         | Bin 0 -> 7117 bytes
 .../cep-migration-conditions-flink1.11-snapshot         | Bin 0 -> 7125 bytes
 ...gration-single-pattern-afterwards-flink1.10-snapshot | Bin 0 -> 6871 bytes
 ...gration-single-pattern-afterwards-flink1.11-snapshot | Bin 0 -> 6879 bytes
 ...ep-migration-starting-new-pattern-flink1.10-snapshot | Bin 0 -> 7270 bytes
 ...ep-migration-starting-new-pattern-flink1.11-snapshot | Bin 0 -> 7278 bytes
 .../windowing/WindowOperatorMigrationTest.java          |   4 +++-
 ...p-migration-test-apply-event-time-flink1.10-snapshot | Bin 0 -> 1753 bytes
 ...p-migration-test-apply-event-time-flink1.11-snapshot | Bin 0 -> 1761 bytes
 ...ration-test-apply-processing-time-flink1.10-snapshot | Bin 0 -> 1645 bytes
 ...ration-test-apply-processing-time-flink1.11-snapshot | Bin 0 -> 1653 bytes
 ...igration-test-kryo-serialized-key-flink1.10-snapshot | Bin 0 -> 3975 bytes
 ...igration-test-kryo-serialized-key-flink1.11-snapshot | Bin 0 -> 3983 bytes
 ...-migration-test-reduce-event-time-flink1.10-snapshot | Bin 0 -> 1609 bytes
 ...-migration-test-reduce-event-time-flink1.11-snapshot | Bin 0 -> 1617 bytes
 ...ation-test-reduce-processing-time-flink1.10-snapshot | Bin 0 -> 1550 bytes
 ...ation-test-reduce-processing-time-flink1.11-snapshot | Bin 0 -> 1558 bytes
 ...est-session-with-stateful-trigger-flink1.10-snapshot | Bin 0 -> 2661 bytes
 ...est-session-with-stateful-trigger-flink1.11-snapshot | Bin 0 -> 2669 bytes
 ...ession-with-stateful-trigger-mint-flink1.10-snapshot | Bin 0 -> 2155 bytes
 ...ession-with-stateful-trigger-mint-flink1.11-snapshot | Bin 0 -> 2163 bytes
 .../_metadata                                           | Bin 0 -> 41481 bytes
 .../_metadata                                           | Bin 0 -> 41481 bytes
 .../_metadata                                           | Bin 0 -> 41584 bytes
 .../_metadata                                           | Bin 0 -> 41584 bytes
 .../_metadata                                           | Bin 0 -> 53342 bytes
 .../_metadata                                           | Bin 0 -> 53342 bytes
 .../_metadata                                           | Bin 0 -> 53419 bytes
 .../_metadata                                           | Bin 0 -> 53419 bytes
 .../migration/StatefulJobSavepointMigrationITCase.scala |   6 +++++-
 .../StatefulJobWBroadcastStateMigrationITCase.scala     |   6 +++++-
 47 files changed, 25 insertions(+), 7 deletions(-)
 create mode 100644 flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.10-snapshot
 create mode 100644 flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.11-snapshot
 create mode 100644 flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.10-empty-state-snapshot
 create mode 100644 flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.10-snapshot
 create mode 100644 flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.11-empty-state-snapshot
 create mode 100644 flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.11-snapshot
 create mode 100644 flink-fs-tests/src/test/resources/monitoring-function-migration-test-1594559333000-flink1.10-snapshot
 create mode 100644 flink-fs-tests/src/test/resources/monitoring-function-migration-test-1594561663000-flink1.11-snapshot
 create mode 100644 flink-fs-tests/src/test/resources/reader-migration-test-flink1.10-snapshot
 create mode 100644 flink-fs-tests/src/test/resources/reader-migration-test-flink1.11-snapshot
 create mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.10-snapshot
 create mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.11-snapshot
 create mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.10-snapshot
 create mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.11-snapshot
 create mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.10-snapshot
 create mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.11-snapshot
 create mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.10-snapshot
 create mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.11-snapshot
 create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.10-snapshot
 create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.11-snapshot
 create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.10-snapshot
 create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.11-snapshot
 create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.10-snapshot
 create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.11-snapshot
 create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.10-snapshot
 create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.11-snapshot
 create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.10-snapshot
 create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.11-snapshot
 create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.10-snapshot
 create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.11-snapshot
 create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.10-snapshot
 create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.11-snapshot
 create mode 100644 flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.10-jobmanager-savepoint/_metadata
 create mode 100644 flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.10-rocksdb-savepoint/_metadata
 create mode 100644 flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.11-jobmanager-savepoint/_metadata
 create mode 100644 flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metadata
 create mode 100644 flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.10-jobmanager-savepoint/_metadata
 create mode 100644 flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.10-rocksdb-savepoint/_metadata
 create mode 100644 flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.11-jobmanager-savepoint/_metadata
 create mode 100644 flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metadata