Re: HashMap/HashSet Serialization Issue

Thanks very much. Regards, Charith On Sat, Jan 7, 2017 at 3:42 AM, Jark Wu wrote: > Hi Charith, > > The LOG message has nothing to worry about. The HashMap and HashSet > members in your POJO is not a PojoType, > so they will be handled as GenericType, i.e. will be >

Re: HashMap/HashSet Serialization Issue

Hi Charith, The LOG message has nothing to worry about. The HashMap and HashSet members in your POJO is not a PojoType, so they will be handled as GenericType, i.e. will be serialized/deserialized by Kryo. But your custom POJO type will still recognized as PojoType, i.e. will be

Re: HashMap/HashSet Serialization Issue

My understanding is HashMap doesn't work with Flink Native serialization framework, though I might be wrong. This might worth reading ​ https://cwiki.apache.org/confluence/display/FLINK/Type+System,+Type+Extraction,+Serialization -Chen​ On Fri, Jan 6, 2017 at 6:06 PM, Charith Wickramarachchi <

HashMap/HashSet Serialization Issue

Hi All, I am using flink-gelly and using a custom POJO type as the VertexValue/MessageType (I am using the vertex-centric model). The POJO contains HashMap/HashSet as members. While executing the job I am getting following Log message. 17:50:53,582 INFO