Yes, it's possible. You may refer to the example here: https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/serialization/types_serialization/#most-frequent-issues
Best, Zhanghao Chen ________________________________ From: patricia lee <plee3...@gmail.com> Sent: Thursday, July 10, 2025 19:44 To: Zhanghao Chen <zhanghao.c...@outlook.com> Cc: user@flink.apache.org <user@flink.apache.org> Subject: Re: Flink 2.0 Migration Execution registerTypes Hi, Thanks for the update. One more question though.. If we set it to pipeline, it means it will get applied to the whole project itself? The problem is, our set up, is that the project has the registerPojoType as params. Therefore there would be different class serialization for each executionEnv. Is there anyway we can set it programmatically? If not how can we achieve multiple class serialization class for each different execution envs? Thank you. On Thu, Jul 10, 2025, 7:00 PM Zhanghao Chen <zhanghao.c...@outlook.com<mailto:zhanghao.c...@outlook.com>> wrote: Hi Patricia, You may register the type using the new config pipeline.serialization-config [1]. I've created a new JIRA issue [2] to fix the doc. [1] https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/deployment/config/#pipeline-serialization-config [2] https://issues.apache.org/jira/browse/FLINK-38078 Best, Zhanghao Chen ________________________________ From: patricia lee <plee3...@gmail.com<mailto:plee3...@gmail.com>> Sent: Thursday, July 10, 2025 16:06 To: user@flink.apache.org<mailto:user@flink.apache.org> <user@flink.apache.org<mailto:user@flink.apache.org>> Subject: Flink 2.0 Migration Execution registerTypes Hi, We are currently migrating from Flink version 1.18 to Flink version 2.0. We have this configuration: StreamExecutionEnvironment env = new StreamExecutionEnvironment(); env.setRegisterTypes(MyClass.class); In flink 2.0, if our understanding is correct, we'll use this registerPojoType instead. However, this method does not exist. So how are we going to register the class? Thanks https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/dev/datastream/execution/execution_configuration
