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> 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> > *Sent:* Thursday, July 10, 2025 16:06 > *To:* user@flink.apache.org <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 > > >
