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. Thanks, Sai Vishnu Soudri
