Oh. So you mean if I write a custom sink for a db, I just need to create
one connection in the open() method and then the invoke() method will reuse
it ? Basically I need to do 35k-50k+ upserts in postgres. Can I reuse
JDBCOutputFormat
for this purpose ? I couldn't find a proper document describing how sinks
works in flink.



On Tue, Jul 5, 2016 at 2:41 PM, Stefano Bortoli <s.bort...@gmail.com> wrote:

> The connection will be managed by the splitManager, no need of using a
> pool. However, if you had to, probably you should look into
> establishConnection() method of the JDBCInputFormat.
>
>
>
> 2016-07-05 10:52 GMT+02:00 Flavio Pompermaier <pomperma...@okkam.it>:
>
>> why do you need a connection pool?
>> On 5 Jul 2016 11:41, "Harikrishnan S" <hihari...@gmail.com> 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 <hihari...@gmail.com>
>>> 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 <hihari...@gmail.com>
>>>> wrote:
>>>>
>>>>> Hi,
>>>>>
>>>>> Are there any examples of implementing a jdbc sink in flink using a
>>>>> connection pool ?
>>>>>
>>>>> Thanks
>>>>>
>>>>
>>>>
>>>
>

Reply via email to