lost in case of a failure.
I would recommend to implement a JdbcSinkFunction based on the code of
the JdbcOutputFormat.
If you use the batch JdbcOutputFormat you might get duplicates or lose
data.
Best, Fabian
2017-02-16 15:39 GMT+01:00 Punit Tandel <mailto:punit.tan...@ericsson.com>>
17-02-16 11:06 GMT+01:00 Punit Tandel <mailto:punit.tan...@ericsson.com>>:
Yes i have been following the tutorials and reading from H2 and
writing to H2 works fine, But problem here is data coming from
kafka and writing them to h2 engine does not seems to work and
cant
at the beginning of:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
Looks like plugging in "org.h2.Driver" should do.
On Wed, Feb 15, 2017 at 4:59 PM, Punit Tandel
mailto:punit.tan...@ericsson.com>> wrote:
Hi All
Does fl
Hi All
Does flink jdbc support writing the data into H2 Database?
Thanks
Punit
column names from the input
query (because in the query you can rename/add fields...).. I'd like
to hear opinions about this..unfortunately I don't have the time to
implement this right now :(
On Wed, Feb 8, 2017 at 1:59 PM, Punit Tandel
mailto:punit.tan...@ericsson.com>>
first
row has a null somewhere.
Regards,
Chesnay
On 08.02.2017 10:48, Punit Tandel wrote:
Hi Chesnay
Currently that is what i have done, reading the schema from database
in order to create a new table in jdbc database and writing the rows
coming from jdbcinputformat.
Overall i am trying to
Rows.
Would be cool if you could tell us what you're planning to do with the
schema :)
In any case, to get the schema within the plan then you will have to
query the DB and build it yourself. Note that this
is executed on the client.
Regards,
Chesnay
On 08.02.2017 00:39, Punit Tande
6, 2017 at 11:09 AM, Punit Tandel
mailto:punit.tan...@ericsson.com>> wrote:
> Hi ,
>
> I was looking into flink streaming api and trying to implement
the solution
> for reading the data from jdbc database and writing them to jdbc
databse
> aga
Hi ,
I was looking into flink streaming api and trying to implement the
solution for reading the data from jdbc database and writing them to
jdbc databse again.
At the moment i can see the datastream is returning Row from the
database. dataStream.getType().getGenericParameters() retuning an
