diff --git a/src/main/scala/io/findify/flinkadt/api/serializer/MappedSerializer.scala b/src/main/scala/io/findify/flinkadt/api/serializer/MappedSerializer.scala
index 018d93f..f941d2b 100644
--- a/src/main/scala/io/findify/flinkadt/api/serializer/MappedSerializer.scala
+++ b/src/main/scala/io/findify/flinkadt/api/serializer/MappedSerializer.scala
@@ -53,7 +53,7 @@ object MappedSerializer {
     override def readSnapshot(readVersion: Int, in: DataInputView, userCodeClassLoader: ClassLoader): Unit = {
       val mapperClazz = InstantiationUtil.resolveClassByName[TypeMapper[A, B]](in, userCodeClassLoader)
       mapper = InstantiationUtil.instantiate(mapperClazz)
-      val serClazz = InstantiationUtil.resolveClassByName(in, userCodeClassLoader)
+      val serClazz = InstantiationUtil.resolveClassByName[TypeSerializer[B]](in, userCodeClassLoader)
       ser = InstantiationUtil.instantiate(serClazz)
     }