Re: Alternatives to JDBCAppendTableSink in Flink 1.11

2021-04-21 Thread Austin Cawley-Edwards
Great to hear! Austin On Wed, Apr 21, 2021 at 6:19 AM Sambaran wrote: > Hi Austin, > > Many thanks, we indeed were using the Api incorrectly. Now in local tests > we can see the data population happened in the postgres. > > Have a nice day! > > Regards > Sambaran > > On Tue, Apr 20, 2021 at 8:1

Re: Alternatives to JDBCAppendTableSink in Flink 1.11

2021-04-21 Thread Sambaran
Hi Austin, Many thanks, we indeed were using the Api incorrectly. Now in local tests we can see the data population happened in the postgres. Have a nice day! Regards Sambaran On Tue, Apr 20, 2021 at 8:11 PM Austin Cawley-Edwards < austin.caw...@gmail.com> wrote: > Hi Sambaran, > > I'm not sur

Re: Alternatives to JDBCAppendTableSink in Flink 1.11

2021-04-20 Thread Austin Cawley-Edwards
Hi Sambaran, I'm not sure if this is the best approach, though I don't know your full use case/ implementation. What kind of error do you get when trying to map into a PreparedStatement? I assume you tried something like this? SingleOutputStreamOperator stream = env.fromElements(Row.of("YourProc

Re: Alternatives to JDBCAppendTableSink in Flink 1.11

2021-04-20 Thread Austin Cawley-Edwards
Hey Sambaran, I'm not too familiar with the 1.7 JDBCAppendTableSink, but to make sure I understand what you're current solution looks like, it's something like the following, where you're triggering a procedure on each element of a stream? JDBCAppendTableSink sink = JDBCAppendTableSink.buil