Apache Flink StateFun user email list

2022-04-17 Thread M Singh
Hi: I just wanted to see if this is the right place for Apache Flink StateFun users email list. If it is not, please let me know and I apologize for any inconvenience. Thanks

XXX doesn't exist in the parameters of the SQL statement

2022-04-17 Thread John Tipper
Hi all, I'm having some issues with getting a Flink SQL application to work, where I get an exception and I'm not sure why it's occurring. I have a source table, reading from Kinesis, where the incoming data in JSON format has a "source" and "detail-type" field. CREATE TABLE `input` ( `so

Huge number of GAX-Threads in Flink

2022-04-17 Thread SHREEKANT ANKALA
Hi, we are using Flink 1.13.2 for one of our datalake project to process json files from Google Cloud storage and write to Iceberg tables in S3. After running the application in production for a couple of days, we are noticing that the GAX-Threads in "Flink Task Threadgoup" are growing with out