Handle unregistered nested serializer for compact serialization.

Author: Mehmet Tokgöz

hazelcast/serialization/compact.py

@@ -43,7 +43,9 @@ def __init__(self, compact_serializers: typing.List[CompactSerializer]):
 
     def write(self, out: ObjectDataOutput, obj: typing.Any) -> None:
         clazz = type(obj)
-        serializer = self._type_to_serializer[clazz]
+        serializer = self._type_to_serializer.get(clazz)
+        if serializer is None:
+            raise HazelcastSerializationError('No serializer is registered for class {}.'.format(type(obj).__name__))
         schema = self._type_to_schema.get(clazz)
         if not schema:
             schema = CompactStreamSerializer._build_schema(serializer, obj)

tests/integration/backward_compatible/serialization/compact_test.py

@@ -823,6 +823,26 @@ def get_class(self) -> Nested:
         return Nested
 
 
+class CompactNestedSerializerTest(CompactTestBase):
+
+    def test_missing_nested_serializer(self):
+        serializer = SomeFieldsSerializer.from_kinds(FIELD_KINDS)
+        fields = {kind.name.lower(): REFERENCE_OBJECTS[kind] for kind in FIELD_KINDS}
+
+        config = {
+            "cluster_name": self.cluster.id,
+            "compact_serializers": [serializer]
+        }
+
+        client = self.create_client(config)
+
+        map_name = random_string()
+        m = client.get_map(map_name).blocking()
+
+        with self.assertRaisesRegex(HazelcastSerializationError, "No serializer is registered for class Nested."):
+            m.put("key", SomeFields(**fields))
+
+
 class FieldDefinition:
     def __init__(
         self,