Call for Presentations: Flink Forward Seattle 2023

2023-06-08 Thread Jing Ge via user
Dear Flink developers & users, We hope this email finds you well. We are excited to announce the Call for Presentations for the upcoming Flink Forward Seattle 2023, the premier event dedicated to Apache Flink and stream processing technologies. As a prominent figure in the field, we invite you to

Re: [DISCUSS] Status of Statefun Project

2023-06-08 Thread Galen Warren via user
Thanks Martijn. Personally, I'm already using a local fork of Statefun that is compatible with Flink 1.16.x, so I wouldn't have any need for a released version compatible with 1.15.x. I'd be happy to do the PRs to modify Statefun to work with new versions of Flink as they come along. As for testi

Re: [DISCUSS] Status of Statefun Project

2023-06-08 Thread Martijn Visser
Hi all, Apologies for the late reply. I'm willing to help out with merging requests in Statefun to keep them compatible with new Flink releases and create new releases. I do think that validation of the functionality of these releases depends a lot on those who do these compatibility updates, wit

Re: PyFlink Error JAR files

2023-06-08 Thread Leo
Hi  Kadiyala, I think that there  is a typo from your email:     Fink  version 1.7.1 May be  1.17.1  ?     About the error,  The reason why your code can't run successfully is: the class "*org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer" had been obsolete  since Flink 1