Hi, We are currently migrating our flink projects from version 1.18 to 2.0.
We have this part of the codes that we set the model in the StreamExecutionEnvironment env = new StreamExecutionEnvironment(); env.setRegisterTypes(MyClass.class); Right now in Flink 2.0, I followed this