Thanks for driving this, Yong. This FLIP look good to me overall.
I also used a similar approach to decouple the serializer from ExecutionConfig in the PoC of DataStream API V2. I'm +1 for this. Best regards, Weijie Xintong Song <tonysong...@gmail.com> 于2023年12月12日周二 12:10写道： > Thanks for working on this, Yong. > > The usability of the serialization mechanism has indeed been a pain for a > long time. > > The proposed changes look good to me. +1 from my side. > > Best, > > Xintong > > > > On Thu, Dec 7, 2023 at 10:36 AM Yong Fang <zjur...@gmail.com> wrote: > > > Hi devs, > > > > I'd like to start a discussion about FLIP-398: Improve Serialization > > Configuration And Usage In Flink [1]. > > > > Currently, users can register custom data types and serializers in Flink > > jobs through various methods, including registration in code, > > configuration, and annotations. These lead to difficulties in upgrading > > Flink jobs and priority issues. > > > > In flink-2.0 we would like to manage job data types and serializers > through > > configurations. This FLIP will introduce a unified option for data type > and > > serializer and users can configure all custom data types and > > pojo/kryo/custom serializers. In addition, this FLIP will add more > built-in > > serializers for complex data types such as List and Map, and optimize the > > management of Avro Serializers. > > > > Looking forward to hearing from you, thanks! > > > > [1] > > > > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-398%3A+Improve+Serialization+Configuration+And+Usage+In+Flink > > > > Best, > > Fang Yong > > >
