Is there a way in Flink to instantiate or open connections (to cache/db) at
global level, so that it can be reused across many process functions rather
than doing it in each operator's open()?Along with opening, also wanted to
know if there is a way to close them at job level stop, such that they are
closed at the very end after each operator close() method is complete.
Basically the idea is to maintain a single instance at global level and
close its session as a last step after each opertor close is complete.


Reply via email to