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
> serialized/deserialized by K
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 serialized/des
Thanks very much.
Regards,
Charith
On Fri, Jan 6, 2017 at 7:44 PM, Chen Qin wrote:
> 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,+T
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 <
c
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 org.apache.flink.api.java.typeutils.TypeEx
