Hello everyone! After I upgraded from jdk11 to jdk17, my code

List<Tuple3<String,LocalDateTime, Long>> occupyTimeOutTimesTuple2List = collection.flatMap(new OccupySecDuration(OccupyPer.PER_USAGE)).collect();

reported the following error

java.lang.IllegalArgumentException: Unable to create serializer "com.esotericsoftware.kryo.serializers.FieldSerializer" for class: java.time.LocalDateTime

I upgraded my flink-clients to the latest version and still could not solve this problem. Is there any good solution?

There has been no Flink release yet that's compatible with JDK17

Is there currently a plan to support JDK17?

Yes, see https://lists.apache.org/thread/mz0m6wqjmqy8htob3w4469pjbg9305do

Thanks

Will this FLIP be included in the version supporting JDK17? There have been many improvements to Kryo from the old 2.24.0 version. https://cwiki.apache.org/confluence/display/FLINK/FLIP-317%3A+Upgrade+Kryo+from+2.24.0+to+5.5.0

Only if it gets voted on and then implemented in time

Thanks. I was a maintainer of the Incubator project Apache Heron, which we recently retired. I'm hoping to get more active with Flink. How can I follow along and get involved with this discussion? Subscribe to the dev mailing list? Or is there a better forum like this?

The Dev mailing list is definitely the best way to get involved