Cannot write DataSet as csv file

2019-07-06 Thread Soheil Pourbafrani
Hi, Using the JDBCInputFormat I loaded a DataSet type. When I tried to save it as CSV file it errors: java.lang.ClassCastException: org.apache.flink.types.Row cannot be cast to org.apache.flink.api.java.tuple.Tuple That's while I can save it as a text file. Here is the code. DataSet dataset = en

Flink best configurations for Production

2019-07-06 Thread Cam Mach
Hello Flink community, I believe the question below has been already asked, but since I couldn't find my answer from internet, I'd love to reach out the community for help. We basically want to find out the best configurations for Flink that running on Kubernetes to achieve the best performanc

Re: Queryable state and TTL

2019-07-06 Thread Eron Wright
Here's a PR for queryable state TLS that I closed because I didn't have time, and because I get the impression that the queryable state feature is used very often.Feel free to take it up, if you like. https://github.com/apache/flink/pull/6626 -Eron On Wed, Jul 3, 2019 at 11:21 PM Avi Levi wr

Re: Queryable state and TTL

2019-07-06 Thread Avi Levi
Thanks, I'll check it out. On Sun, Jul 7, 2019 at 5:40 AM Eron Wright wrote: > *This Message originated outside your organization.* > -- > Here's a PR for queryable state TLS that I closed because I didn't have > time, and because I get the impression that the queryab