Hi team,

I am using the JdbcSink from flink-connector-jdbc artifact, version
3.1.0-1.17. I am trying to write a Sink wrapper that will internally call
the invoke method and open method of jdbc sink. While implementing, I see
that JdbcSink.*sink() *returns a SinkFunction which only exposes the invoke
method and not the open method.

Would appreciate any suggestions on how I can implement this. To add to the
requirement, the use case is to try and enclose the invoke operation in a
try catch block so that any exception during the db write process can be
caught and handled properly.


Sai Vishnu Soudri

Reply via email to