[DISCUSS] Issue tracking workflow

2022-10-23 Thread Xintong Song
Hi devs and users, As many of you may have already noticed, Infra announced that they will soon disable public Jira account signups [1]. That means, in order for someone who is not yet a Jira user to open or comment on an issue, he/she has to first reach out to a PMC member to create an account fo

Re: [DISCUSS] Planning Flink 1.17

2022-10-23 Thread Zhu Zhu
Thanks for kicking off the new release. +1 for January 17th as the feature freeze date :) +1 for Qingsheng, Leonard, Martijn and Matthias as release managers Thanks, Zhu Dong Lin 于2022年10月23日周日 15:09写道: > > Thanks for kicking off the release plan. > > +1 for the proposed timeline. > > Best, > D

Re: How to use connectors in PyFlink 1.15.0 when not defined in Python API?

2022-10-23 Thread Levan Huyen
Hi all, I'm trying to follow the code in 1.16 SNAPSHOT to have a Kinesis sink in PyFlink 1.15, to write the output of a KeyedCoProcessFunction to Kinesis. 1. If I use ".set_serialization_schema(SimpleStringSchema())", then I got the error message: java.lang.ClassCastException: class [B cannot be

Re: [DISCUSS] Planning Flink 1.17

2022-10-23 Thread Dong Lin
Thanks for kicking off the release plan. +1 for the proposed timeline. Best, Dong On Thu, Oct 20, 2022 at 3:46 PM Qingsheng Ren wrote: > Hi everyone, > > As we are approaching the official release of Flink 1.16, it’s a good time > to kick off some discussions and march toward 1.17. > > - Rele