Flink scala or Java - Dataload from CSV to database..

Hi Guys, We are in the process of creating POC, 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 --> SQLSERVER --> AWS Redshift could you please some one help me on that.. Cheers Ram

Re: Guys, How to use JDBC connection in Flink using Scala

> On 24 Sep 2016, at 16:08, ram kumar wrote: > > I am wondering is that possible to add JDBC connection or url as a > source or target in Flink using Scala. > > Could you kindly some one help me on this? if you have any sample code > please share it here. > > What’s your

Guys, How to use JDBC connection in Flink using Scala

Hi Team, I am wondering is that possible to add JDBC connection or url as a source or target in Flink using Scala. Could you kindly some one help me on this? if you have any sample code please share it here. *Thanks* *Ram*

Error when executing job

Hi, getting below error when executing twitter flink job, org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Job execution failed. at org.apache.flink.client.program.Client.runBlocking(Client.java:370) at org.apache.flink.streaming.api.environment.S

Re: IOException when trying flink-twitter example

help you figure out what is happening > (loss of connection, etc). > > On Mon, Feb 15, 2016 at 1:32 PM, ram kumar > wrote: > >> org.apache.flink.streaming.connectors.twitter.TwitterFilterSource - >> Initializing Twitter Streaming API connection >> 12:27:32,134 INFO

Re: IOException when trying flink-twitter example

nd out > about the reason for the failed connection. > > Cheers, > Max > > On Thu, Feb 11, 2016 at 9:30 AM, ram kumar > wrote: > > Hi, > > > > Got following exception in taskmanager logs when running > > TwitterFilterSourceExample, &

IOException when trying flink-twitter example

Hi, Got following exception in taskmanager logs when running TwitterFilterSourceExample, 08:25:19,207 WARN com.twitter.hbc.httpclient.ClientBase - twitterSourceClient failed to establish connection properly 08:25:19,207 INFO com.twitter.hbc.httpclient.ClientBase