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