Re: [PR] Flink 1.17 [beam]

["je-ik (via GitHub)" <gi...@apache.org>]

je-ik commented on PR #30197:
URL: https://github.com/apache/beam/pull/30197#issuecomment-2058715674

   Unfortunately, upgrading Flink has still issues with upgrading various sources (due to Java serialization). Upgrade from 2.55.0 to 2.56.0 (in my testing Pipeline) is blocked due to incompatible change of KafkaIO.Read (added option).
   
   Having said that, upgrade from 2.56.0 Flink 1.16 to Flink 1.17 works and that is as far as we can get. We need to merge https://github.com/apache/beam/pull/30987 and then we would need to implement https://github.com/apache/beam/issues/30385 and ideally https://github.com/apache/beam/issues/21897.
   
   Other than that, this is ready from my part @Abacn, with follow-up https://github.com/apache/beam/pull/30988.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org