Re: Custom type serializer inside Flink state

2019-08-07 Thread Ying Xu
Hi Yun: Thanks for the quick reply. Thanks for pointing to FLINK-11333 , will take a look. We are currently using Flink 1.8.0. To summarize the behavior: 1) In the first version of the Flink app, there is a protobuf class getting registered f

Re: Custom type serializer inside Flink state

2019-08-07 Thread Yun Tang
Hi Ying What version of Flink are you using and please more exception stack. Moreover, what is the relationship between `MyProtoClass2` and `MyProtoClass1`? As far as I know, registering the Message class should not be the proper solution. For the 2nd question, you could refer to FLINK-11333 [1