The basic idea was that I would create a pool of connections in the open() method in a custom sink and each invoke() method gets one connection from the pool and does the upserts needed. I might have misunderstood how sinks work in flink though.
On Tue, Jul 5, 2016 at 2:22 PM, Flavio Pompermaier <[email protected]> wrote: > why do you need a connection pool? > On 5 Jul 2016 11:41, "Harikrishnan S" <[email protected]> wrote: > >> Hi, >> >> Are there any examples of implementing a jdbc sink in flink using a >> connection pool ? >> >> Thanks >> >> On Tue, Jul 5, 2016 at 2:00 PM, Harikrishnan S <[email protected]> >> wrote: >> >>> Hi, >>> >>> Are there any examples of implementing a jdbc sink in flink using a >>> connection pool ? >>> >>> Thanks >>> >>> On Tue, Jul 5, 2016 at 1:57 PM, Harikrishnan S <[email protected]> >>> wrote: >>> >>>> Hi, >>>> >>>> Are there any examples of implementing a jdbc sink in flink using a >>>> connection pool ? >>>> >>>> Thanks >>>> >>> >>> >>
