Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5732#discussion_r176222855
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/state/StateDescriptorTest.java
---
@@ -130,6 +135,31 @@ public void
testInitializeSerializerAfterSerializationWithCustomConfig() throws
.getRegistration(File.class).getId() > 0);
}
+ //
------------------------------------------------------------------------
+ // Tests for serializer initialization
+ //
------------------------------------------------------------------------
+
+ /**
+ * FLINK-6775, tests that the returned serializer is duplicated.
+ * This allows to share the state descriptor across threads.
+ */
+ @Test
+ public void testSerializerDuplication() throws Exception {
+ // we need a serializer that actually duplicates for testing (a
stateful one)
--- End diff --
Same as above, we should assert that assumption
---
