Re: DataStream jdbc sink

2016-01-13 Thread Traku traku
thank you!! 2016-01-13 20:51 GMT+01:00 Matthias J. Sax : > Hi, > > use JDBCOutputFormatBuilder to set all required parameters: > > > JDBCOutputFormatBuilder builder = > JDBCOutputFormat.buildJDBCOutputFormat(); > > builder.setDBUrl(...) > > // and more > > > > var.write(builder.finish, OL); > > -

Re: DataStream jdbc sink

2016-01-13 Thread Matthias J. Sax
Hi, use JDBCOutputFormatBuilder to set all required parameters: > JDBCOutputFormatBuilder builder = JDBCOutputFormat.buildJDBCOutputFormat(); > builder.setDBUrl(...) > // and more > > var.write(builder.finish, OL); -Matthias On 01/13/2016 06:21 PM, Traku traku wrote: > Hi everyone. > > I'm t

DataStream jdbc sink

2016-01-13 Thread Traku traku
Hi everyone. I'm trying to migrate some code to flink 0.10 and I'm having a problem. I try to create a custom sink to insert the data to a postgresql database. My code was this. var.output( // build and configure OutputFormat JDBCOutputFormat .buildJDBCOutputForma