- 22 2月, 2019 16 次提交
-
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
[FLINK-11485] [core] Refactor multiple nested serializer compatibility resolution logic to CompositeTypeSerializerUtil This commit refactors the logic of resolving overall compatibility results across multiple nested serializers of a composite serializer out of the CompositeTypeSerializerSnapshot class. This allows us to reuse this functionality when implementing the compatibility check for the PojoSerializerSnapshot
-
由 Tzu-Li (Gordon) Tai 提交于
Having "Linked" in the name better reflects the fact that the map preserves entry ordering.
-
由 Tzu-Li (Gordon) Tai 提交于
This utility class may commonly be used by the KryoSerializer and the PojoSerializer. This commit moves the utility to a more suitable package and adjusts usage access.
-
由 Igal Shilman 提交于
This closes #7496.
-
由 Igal Shilman 提交于
-
由 Igal Shilman 提交于
-
由 Igal Shilman 提交于
This commit adds two more tests to TypeSerializerSnapshotMigrationTestBase that validates that the new serializer are able to read previously stored data (perhaps after reconfiguration).
-
由 Igal Shilman 提交于
This commit adds a new KryoSerializerSnapshot class and uses that instead of the now deprecated KryoSerializerConfigSnapshot. It also adds migration tests for the new KryoSerializerSnapshot, extending the TypeSerializerSnapshotMigrationTestBase.
-
由 Igal Shilman 提交于
[FLINK-11323] [tests] Adjust serializer tests to respect new COMPATIBLE_WITH_RECONFIGURED_SERIALIZER option Adjust serializer tests to use the reconfigured serializer if such serializer was provided.
-
由 Igal Shilman 提交于
An OptinalMap is a map that allows null values and null keys (as long as a name is assosicated with them. This would replace the usage of DummyUnloadableClass and DummyUnloadableSerializer within KryoSerializerSnapshot.
-
由 Tzu-Li (Gordon) Tai 提交于
The test enum type written in test resource files has different serialVersionUIDs generated between Scala 2.11 / 2.12. The test fails in 2.12 because we wrote the test files with 2.11. This commit fixes that by explicitly setting a fixed serialVersionUID for the test enum type.
-
由 zentol 提交于
-
由 Chesnay Schepler 提交于
-
由 Gary Yao 提交于
-
- 21 2月, 2019 24 次提交
-
-
由 zentol 提交于
-
由 zentol 提交于
-
由 tison 提交于
-
由 tison 提交于
-
由 tison 提交于
-
由 klion26 提交于
-
由 Aljoscha Krettek 提交于
First, this inverts the if statements to make the code more readable and maintainable. Then, this changes the check to report *incompatible* when the order of enums changes or when enums are removed because we currently don't maintain a map of enum ids to enum values ourselves and therefore cannot migrate or reconfigure the serializer to read data that was serialized with the old mapping.
-
由 Aljoscha Krettek 提交于
Before, this was trying to create an Enumeration and cast it to a TypeSerializer. Creating the enumeration would fail because it is a Scala Object, i.e. a singleton. The cast would also fail. This now uses inspection to create an instance of the Enumeration and then uses that to create an EnumValueSerializer.
-
由 Aljoscha Krettek 提交于
This logic will never be used because the new snapshot will never be used to deserialize an old config snapshot.
-
由 Aljoscha Krettek 提交于
Using an IntSerialize technically makes EnumValueSerializer a composite serializer, which it doesn't have to be. This decouples EnumValueSerializer from any future changes to IntSerializer.
-
由 klion26 提交于
This commit migrate EnumValueSerializer to use new serialization compatibilty abstractions * add a new class `ScalaEnumSerializerSnapshot` * return a `ScalaEnumSerializerConfigSnapshot ` with `ScalaEnumSerializerSnapshot` when calling `EnumValueSerializer#snapshotConfiguration` * add a migration test `EnumValueSerializerSnapshotMigrationTest` to test the compatibility * remove function `EnumValueSerializer#ensureCompatibility()`
-
由 leesf 提交于
-
由 wenhuitang 提交于
-
由 Stefan Richter 提交于
This closes #7753.
-
由 Benchao Li 提交于
[FLINK-11699] Use isEmpty() for address comparison in AbstractDispatcherResourceManagerComponentFactory This closes #7783.
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
We also don't check the state on every call anymore.
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
This makes it easier to read messages of failing tests.
-
由 Aljoscha Krettek 提交于
This makes it easier to understand failing tests where serializers are being compared.
-
由 Aljoscha Krettek 提交于
Before, it wasn't comparing the ordering of enum values, i.e. the mapping of indices to enum values.
-
由 Igal Shilman 提交于
This changes the new EnumSerializer Snapshot to hold Enums, instead of their String representation (we to the mapping from and to Enum in the read/write methods). This also changes the compatibility checks to detect changes in enum ordering and then report that only reconfiguration is required.
-