table api conditionally double quoting data in csv

2022-04-09 Thread Shameet Doshi
Hello, I am using the table api in pyflink to generate a csv . What i noticed is that its conditionally adding quotes around the data. What I want is quotes around all the data csv is being created in s3 e.g in output below the data in last column was not quoted "transaction_idgeorge.bl...@reqres

Re: Flink Kafka Issue with EXACTLY_ONCE semantics

2022-04-09 Thread Praneeth Ramesh
Hi Frank Thanks for the response. I see that the min.isr value is 2 and replication factor is 4 in my case. Do you see any issues with these values..? Thank you in advance On Fri, Apr 8, 2022 at 11:28 PM Frank Dekervel wrote: > Hello, > > Check if your topic replication factor is not below mi

Unsubscribe

2022-04-09 Thread Abu Bakar Siddiqur Rahman Rocky

StateFun - How to run the application in a Flink cluster and IDE

2022-04-09 Thread M Singh
Hi Folks: I would like to run StateFun application in a flink cluster just like a Flink application. I found the instructions in (https://nightlies.apache.org/flink/flink-statefun-docs-release-3.2/docs/deployment/overview/) but could not find if there is any difference in how to build the jar b/