Re: Custom type serializer inside Flink state

2019-08-07 Thread Ying Xu
gt; > CC @Tzu-Li (Gordon) Tai<mailto:tzuli...@apache.org> as he might provide > more information about this. > > [1] https://issues.apache.org/jira/browse/FLINK-11333 > > Best > Yun Tang > > > From: Ying Xu > Sent: Thursday, August

Re: Custom type serializer inside Flink state

2019-08-07 Thread Yun Tang
o: dev@flink.apache.org Subject: Custom type serializer inside Flink state Hi Flink community: Our Flink application sends different types of protobuf messages on-the-wire. Since protobuf cannot be handled by Flink type serializer, we had to register custom Kyro serializer: env.get

Custom type serializer inside Flink state

2019-08-07 Thread Ying Xu
Hi Flink community: Our Flink application sends different types of protobuf messages on-the-wire. Since protobuf cannot be handled by Flink type serializer, we had to register custom Kyro serializer: env.getConfig().*registerTypeWithKryoSerializer*(MyProtoClass1.class,