(note: please keep user@flink.apache.org included in replies) Ah, I see. Then no, this is not provided by Flink. When I've used dependency inject with Flink in the past, I instantiated everything in the `open()` method of the Flink Rich* classes. Could you solve this by having a common base Sink class or builder that does the configuring? I'm just wondering why it's necessary to solve it in Flink itself.
Best, Austin On Tue, Feb 14, 2023 at 11:05 AM Yashoda Krishna T < yashoda.kris...@unbxd.com> wrote: > This is my use case. > I have a sink function to push streaming data to S3. And I have a class > lets call S3ConnProvider that provides me a connection object to S3, and a > class lets say S3Util that has functions over S3 which injects > S3ConnProvider. > If dependency injection works I can inject S3Util alone in my SinkFunction > class. If not I have to initialize S3ConnProvider first and then S3Util. > This can become complex if there are too many initializations > required depending on the use case. > >>
