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
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
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
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