Re: Flink 2.0 Migration Execution registerTypes

2025-07-10 Thread Zhanghao Chen
ly 10, 2025 19:44 To: Zhanghao Chen Cc: 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 tha

Re: Flink 2.0 Migration Execution registerTypes

2025-07-10 Thread patricia lee
-38078 > > Best, > Zhanghao Chen > -- > *From:* patricia lee > *Sent:* Thursday, July 10, 2025 16:06 > *To:* user@flink.apache.org > *Subject:* Flink 2.0 Migration Execution registerTypes > > Hi, > > We are currently migrating from Fli

Re: Flink 2.0 Migration Execution registerTypes

2025-07-10 Thread Zhanghao Chen
e.org/jira/browse/FLINK-38078 Best, Zhanghao Chen From: patricia lee Sent: Thursday, July 10, 2025 16:06 To: 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

Flink 2.0 Migration Execution registerTypes

2025-07-10 Thread patricia lee
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