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

2016-09-24 Thread Felix Dreissig
Hi Ram, On 24 Sep 2016, at 18:32, ram kumar wrote: > To connect redshift ( for staging and production database ) I need to setup > JDBC connection in Flink Scala. > > > > Kafka (Source) > Flink (JDBC) ---> AWS ( S3 and > Redshift) Target. > > > Could you please sug

Re: How can I prove ....

2016-09-24 Thread Felix Dreissig
Hi Amir, On 23 Sep 2016, at 19:57, amir bahmanyari wrote: > Currently running with 512 slots all taken as indicated by the dashboard. > Are we talking about this? Then yes based on no available slots, I assume I > am at 512 . I guess Stephan is referring to the parallelism of single operators a

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

2016-09-24 Thread Felix Dreissig
Hi Ram, 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 intended use case? Gett