Re: Dependency injection and flink.

2020-11-09 Thread Arvid Heise
e made progress on providing the initialization >> hooks as described in your linked thread. Note that the community is busy >> getting Flink 1.12 done, so it might take a while for more answers. >> >> Best, >> >> Arvid >> >> On Tue, Nov 3, 2020 at 12:03

Re: Dependency injection and flink.

2020-11-04 Thread Dan Diephouse
work with flink >> within my company. When I searched the user-mailing list, I found the >> following thread in flink which discussed about this in the past: >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Dependency-Injection-and-Flink-td18880.html >>

Re: Dependency injection and flink.

2020-11-03 Thread Arvid Heise
> my company. When I searched the user-mailing list, I found the following > thread in flink which discussed about this in the past: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Dependency-Injection-and-Flink-td18880.html > > Since the thread was ~2 yrs old, I&

Dependency injection and flink.

2020-11-02 Thread santhosh venkat
Hi, I'm trying to integrate a dependency injection framework with flink within my company. When I searched the user-mailing list, I found the following thread in flink which discussed about this in the past: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Dependency-Inje

Re: Dependency Injection and Flink

2018-03-17 Thread Steven Wu
Stephan, That would be helpful. On job manager side, entry class provides such an entry point hook. The problem is on the task manager side, where we don't have such an initialization/entry point. I have brought up the same question 3 months ago in this list with subject "entrypoint for executing

Re: Dependency Injection and Flink

2018-03-15 Thread Stephan Ewen
Would it help to be able to register "initializers", meaning some classes/methods that will be called at every process entry point, to set up something like this? On Tue, Mar 13, 2018 at 7:56 PM, Steven Wu wrote: > Xiaochuan, > > We are doing exactly as you described. We keep the injector as a

Re: Dependency Injection and Flink

2018-03-13 Thread Steven Wu
Xiaochuan, We are doing exactly as you described. We keep the injector as a global static var. But we extend from FlinkJobManager and FlinkTaskManager to override main method and initialize the injector (and other things) during JVM startup, which does cause tight code coupling. It is a little pa

Dependency Injection and Flink

2018-03-13 Thread XiaoChuan Yu
Hi, I'm evaluating Flink with the intent to integrate it into a Java project that uses a lot of dependency injection via Guice. What would be the best way to work with DI/Guice given that injected fields aren't Serializable? I looked at this StackOverflow answer so far. To my understanding the str