Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
-
None
Description
Users affected by poor performance might want to understand how Flink is serializing their data.
Therefore, it would be cool to have a tool utility which logs the serializers like this:
SerializerUtils.getSerializers(TypeInformation<POJO> t);
to get
PojoSerializer TupleSerializer IntSer DateSer GenericTypeSer(java.sql.Date) PojoSerializer GenericTypeSer(HashMap)