[flink] branch master updated (1ea2a7a -> 4518a45)

[tw...@apache.org]

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

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


    from 1ea2a7a  [FLINK-25407][network] Fix the issues caused by FLINK-24035
     add 4518a45  [FLINK-25351][annotations] Introduce `FlinkVersion` as a global enum

No new revisions were added by this update.

Summary of changes:
 .../main/java/org/apache/flink/FlinkVersion.java   | 31 +++++++-----
 .../connector/jdbc/xa/JdbcXaSinkMigrationTest.java | 19 ++++---
 .../kafka/FlinkKafkaConsumerBaseMigrationTest.java | 34 ++++++-------
 .../FlinkKafkaProducerMigrationOperatorTest.java   | 17 +++----
 .../kafka/FlinkKafkaProducerMigrationTest.java     | 20 ++++----
 .../connectors/kafka/KafkaMigrationTestBase.java   | 12 ++---
 .../kafka/KafkaSerializerUpgradeTest.java          | 12 ++---
 .../kinesis/FlinkKinesisConsumerMigrationTest.java | 36 +++++++-------
 .../runtime/WritableSerializerUpgradeTest.java     |  8 +--
 .../CompositeTypeSerializerUpgradeTest.java        | 12 ++---
 .../typeutils/TypeSerializerUpgradeTestBase.java   | 38 +++++++-------
 .../base/BasicTypeSerializerUpgradeTest.java       | 54 ++++++++++----------
 ...sicTypeSerializerUpgradeTestSpecifications.java | 52 +++++++++----------
 .../typeutils/base/EnumSerializerUpgradeTest.java  | 12 ++---
 .../typeutils/base/ListSerializerUpgradeTest.java  |  8 +--
 .../typeutils/base/MapSerializerUpgradeTest.java   |  8 +--
 .../array/PrimitiveArraySerializerUpgradeTest.java | 22 ++++----
 ...veArraySerializerUpgradeTestSpecifications.java | 20 ++++----
 .../runtime/CopyableSerializerUpgradeTest.java     |  8 +--
 .../runtime/NullableSerializerUpgradeTest.java     | 12 ++---
 .../runtime/PojoSerializerUpgradeTest.java         | 32 ++++++------
 .../PojoSerializerUpgradeTestSpecifications.java   | 22 ++++----
 .../runtime/RowSerializerUpgradeTest.java          | 14 +++---
 .../runtime/TupleSerializerUpgradeTest.java        |  8 +--
 .../runtime/ValueSerializerUpgradeTest.java        |  8 +--
 .../runtime/kryo/KryoSerializerUpgradeTest.java    | 20 ++++----
 .../avro/typeutils/AvroSerializerUpgradeTest.java  | 12 ++---
 .../ContinuousFileProcessingMigrationTest.java     | 36 +++++++-------
 .../apache/flink/cep/NFASerializerUpgradeTest.java | 26 +++++-----
 .../LockableTypeSerializerUpgradeTest.java         |  8 +--
 .../flink/cep/operator/CEPMigrationTest.java       | 30 +++++------
 ...lueWithProperHashCodeSerializerUpgradeTest.java |  8 +--
 .../ValueArraySerializerUpgradeTest.java           | 40 +++++++--------
 .../state/ArrayListSerializerUpgradeTest.java      |  8 +--
 .../runtime/state/JavaSerializerUpgradeTest.java   |  8 +--
 .../state/VoidNamespaceSerializerUpgradeTest.java  |  8 +--
 .../state/ttl/TtlSerializerUpgradeTest.java        |  8 +--
 .../typeutils/OptionSerializerUpgradeTest.java     |  8 +--
 .../ScalaEitherSerializerUpgradeTest.java          |  8 +--
 .../typeutils/ScalaTrySerializerUpgradeTest.java   |  8 +--
 .../typeutils/EnumValueSerializerUpgradeTest.scala |  7 +--
 .../ScalaCaseClassSerializerUpgradeTest.scala      |  7 +--
 .../TraversableSerializerUpgradeTest.scala         | 23 +++++----
 .../api/datastream/UnionSerializerUpgradeTest.java | 12 ++---
 ...oPhaseCommitSinkStateSerializerUpgradeTest.java | 10 ++--
 .../api/operators/TimerSerializerUpgradeTest.java  |  8 +--
 .../co/BufferEntrySerializerUpgradeTest.java       |  8 +--
 .../windowing/WindowOperatorMigrationTest.java     | 36 +++++++-------
 .../windowing/WindowSerializerUpgradeTest.java     | 12 ++---
 .../StreamElementSerializerUpgradeTest.java        |  8 +--
 .../typeutils/LinkedListSerializerUpgradeTest.java |  8 +--
 .../LegacyStatefulJobSavepointMigrationITCase.java | 22 ++++----
 .../utils/StatefulJobSavepointMigrationITCase.java | 54 ++++++++++----------
 .../StatefulJobWBroadcastStateMigrationITCase.java | 51 ++++++++++---------
 .../TypeSerializerSnapshotMigrationITCase.java     | 58 +++++++++++-----------
 .../AbstractKeyedOperatorRestoreTestBase.java      | 36 +++++++-------
 .../restore/keyed/KeyedComplexChainTest.java       |  6 +--
 .../AbstractNonKeyedOperatorRestoreTestBase.java   | 40 +++++++--------
 .../operator/restore/unkeyed/ChainBreakTest.java   |  6 +--
 .../restore/unkeyed/ChainLengthDecreaseTest.java   |  6 +--
 .../restore/unkeyed/ChainLengthIncreaseTest.java   |  6 +--
 .../unkeyed/ChainLengthStatelessDecreaseTest.java  |  6 +--
 .../operator/restore/unkeyed/ChainOrderTest.java   |  6 +--
 .../operator/restore/unkeyed/ChainUnionTest.java   |  6 +--
 .../StatefulJobSavepointMigrationITCase.scala      | 57 ++++++++++-----------
 ...StatefulJobWBroadcastStateMigrationITCase.scala | 53 ++++++++++----------
 66 files changed, 656 insertions(+), 651 deletions(-)
 rename flink-core/src/test/java/org/apache/flink/testutils/migration/MigrationVersion.java => flink-annotations/src/main/java/org/apache/flink/FlinkVersion.java (71%)