Hi Team,
I am wondering is that possible to add JDBC connection as a source or
target in Flink using Scala.
Could you kindly some one help on this? DB write/sink code is not working.
if you have any sample code please share it here.
*Thanks*
*Sunny*
[image: Inline image 1]
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
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
Hi Guys,
I am facing JDBC error, could you please some one advise me on this error?
$ java -version
java version "1.8.0_102"
Java(TM) SE Runtime Environment (build 1.8.0_102-b14)
Java HotSpot(TM) 64-Bit Server VM (build 25.102-b14, mixed mode)
$ scala -version
Scala code runner version 2.11.
