Re: jdbc.JDBCInputFormat

2016-10-12 Thread sunny patel
Hi guys, I am facing following error message in flink scala JDBC wordcount. could you please advise me on this? *Information:12/10/2016, 10:43 - Compilation completed with 2 errors and 0 warnings in 1s 903ms* */Users/janaidu/faid/src/main/scala/fgid/JDBC.scala* *Error:(17, 67) can't expand macro

Re: AWS S3 and Reshift

2016-10-06 Thread sunny patel
Wed, Oct 5, 2016 at 8:15 AM, sunny patel wrote: > > Hi Guys, > > > > We are in the process of creating Proof of concept., > > I am looking for the sample project - Flink scala or java which can load > > data from database to database or > > CSV to relational d

AWS S3 and Reshift

2016-10-04 Thread sunny patel
Hi Guys, We are in the process of creating Proof of concept., I am looking for the sample project - Flink scala or java which can load data from database to database or CSV to relational database(any). CSV --> S3 --> AWS Redshift could you please some one advise me on that.. C

Re: flink 1.1.2 RichFunction not working

2016-09-27 Thread sunny patel
Hi Chen, Please upload your Flink scala library dependencies. Regards Sunny. On Tue, Sep 27, 2016 at 5:56 PM, Chen Bekor wrote: > Hi, > > Since upgrading to flink 1.1.2 from 1.0.2 - I'm experiencing regression in > my code. In order to Isolate the issue I have written a small flink job > that