Re: How to figure out what's the size of ListState?

2023-05-27 Thread Amir Hossein Sharifzadeh
Thank you Yun for your reply. Yes, I did the same thing and posted my solution here: https://stackoverflow.com/questions/76308686/how-to-figure-out-whats-the-size-of-liststate?noredirect=1#comment134577594_76308686 Best, Anir On Wed, May 24, 2023 at 5:13 AM Yun Tang wrote: > Hi Amir, > > For t

[ANNOUNCE] Apache flink-connector-cassandra 3.1.0 released

2023-05-27 Thread Danny Cranmer
The Apache Flink community is very happy to announce the release of Apache flink-connector-cassandra 3.1.0. This connector supports Flink 1.16 and 1.17. Apache FlinkĀ® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming appli

[jira] [Created] (FLINK-32210) Error import Pyflink.table.descriptors due to python3.10 version mismatch

2023-05-27 Thread Alireza Omidvar (Jira)
Alireza Omidvar created FLINK-32210: --- Summary: Error import Pyflink.table.descriptors due to python3.10 version mismatch Key: FLINK-32210 URL: https://issues.apache.org/jira/browse/FLINK-32210 Proje

Re: [DISCUSS] FLIP-313 Add support of User Defined AsyncTableFunction

2023-05-27 Thread Aitozi
Hi Jing, Thanks for your response. As stated in the FLIP, the purpose of this FLIP is meant to support user-defined async table function. As described in flink document [1] Async table functions are special functions for table sources that perform > a lookup. > So end user can not directly de