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


Reply via email to