Hi Matthias,
Thanks for the information.
Best regards,
Jing
On Thu, Sep 7, 2023 at 5:36 PM Matthias Pohl wrote:
> I don't know about the specifics of the kryo 2.x vs 5.x issues. The
> discussion around FLIP-317 [1] seems to have stalled here. But Java 17 is
> still considered an experimental
I don't know about the specifics of the kryo 2.x vs 5.x issues. The
discussion around FLIP-317 [1] seems to have stalled here. But Java 17 is
still considered an experimental feature as expressed in Flink's roadmap
[2]. So, it should be fine to have it in 1.18. I updated the release notes
of FLINK
Hi folks,
Sorry to come back to this thread, since I saw FLINK-32327 is already
closed and Chesnay announced on 16th June that Flink master branch (at that
time, now it should be both 1.18 and master branches) builds and runs with
Java 17 out-of-the-box. But according to the feedback from Kurt, I'
I think there is some confusion:
Chesnay, not me, recently checked in changes into master so that Flink will
build + test + run with experimental support for Java 17 but with Kryo 2.x
as-is so this will error with Java records. Chesnay created this particular
email thread related to this work.
Hi Kurt,
Thanks for your contribution. I am a little bit confused about the email
title, since your PR[1] is not merged into the master yet. I guess, with
"Experimental Java 17 support", you meant it is available on your branch
which is based on the master.
If I am not mistaken, there is no vote
I built the Flink master branch and tried running this simple Flink app that
uses a Java record:
https://github.com/kurtostfeld/flink-kryo-upgrade-demo/blob/main/flink-record-demo/src/main/java/demo/app/Main.java
It fails with the normal exception that Kryo 2.x throws when you try to
serialize
The master branch now builds and runs with Java 17 out-of-the-box.
Notes:
- a nightly cron build was set up, but I expect it to fail because some
tests only run in the branches and thus weren't covered by my testing.
I'll try to stabilize things over the weekend.
- The Python Kafka connector is
