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%)