Details
-
Bug
-
Status: Open
-
Not a Priority
-
Resolution: Unresolved
-
1.4.2
-
None
Description
According to the documentation, Flink has a specialized serializer for Option type. However, when an Option field is used inside a POJO, the following WARNING appears in TaskManagers' log.
No fields detected for class scala.Option. Cannot be used as a PojoType. Will be handled as GenericType