Java 17 support in Flink

Hi, Will Flink 2.0 support Open JDK - Java 17 ? And Is there any plan for adding Java 17 support in the Flink 1.x series ? All I could see in the documentation is that Java 17 experimental support is there. Thanks in advance for any help !! Regards Anuj

What's the simplest operator to use for this transform?

Hi all, I'm struggling with a data transformation using Pyflink and the DataStream API. I'm open to using the Table API if that is more suitable. My pyflink job ingests three streams from different kafka topics using the kafka connector. These contain json messages, which I parse into a python