flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jark Wu <imj...@gmail.com>
Subject Re: Questions about Flink RichSinkFunction constructor VS open()
Date Tue, 21 Apr 2020 02:28:31 GMT
Hi Jiawei,

Yes, you should initialize connection in open() method, because constructor
is only called in client side (where may can't connect to your database).
Besides, after construction, the RichSinkFunction instance will be
serialized into binary and ship to server (TaskManagers) for
deserialization and execution.
However, connection instances are mostly not serializable (e.g. jdbc
connection). So you can't and shouldn't initialize it in constructor.
open() is the suggested way to do that.


On Tue, 21 Apr 2020 at 09:26, Jiawei Wu <wujiawei5837464@gmail.com> wrote:

> I have posted this question in StackOverflow:
> https://stackoverflow.com/questions/61334549/flink-richsinkfunction-constructor-vs-open
> The question is:
> > Let's say I need to implemnt a custom sink using RichSinkFunction, and I
> need some variables like DBConnection in the sink. Where should I
> initialize the DBConnection´╝č I see most of the articles init the
> DBConnection in the open() method, why not in the constructor?
> A folow up questions is what kind of variables should be inited in
> constructor and what should be init in open()?

View raw message