Re: key_by problem in Pyflink

2021-07-16 Thread Fei Zhao
hanks. Fei Zhao 于2021年7月13日周二 下午5:21写道: > Hi, > > Thanks for your explanation! Adding a line `self.data.contains('xxx')` in > the `process_element2` and all goes well. I will take this as my temporary > solution. > > Looking forward to the next release. > > Best R

Re: key_by problem in Pyflink

2021-07-13 Thread Fei Zhao
Hi, Thanks for your explanation! Adding a line `self.data.contains('xxx')` in the `process_element2` and all goes well. I will take this as my temporary solution. Looking forward to the next release. Best Regards, Fei Xingbo Huang 于2021年7月13日周二 下午4:18写道: > Hi, > > I have created the JIRA[1]