How does one get the configuration map to each worker?
On Wed, Mar 26, 2014 at 6:41 AM, Adam Lewis <[email protected]> wrote: > Or, since this is only being called from prepare at startup anyway, simpler: > > public class InjectorProvider { > > private static Injector injector; > public static synchronized Injector get(Map conf) { > if (injector == null) { > injector = Guice.createInjector( > new DAOModule(conf), > new S3Module(conf)); > } > > return injector; > } > } > > > > > > On Wed, Mar 26, 2014 at 9:26 AM, Svend Vanderveken > <[email protected]> wrote: >> >> > private static Injector injector; >> >> or better: >> >> private static volatile Injector injector; >> >> >> see http://www.cs.umd.edu/~pugh/java/memoryModel/DoubleCheckedLocking.html >> >> >> On Tue, Mar 25, 2014 at 9:55 PM, Patricio Echagüe <[email protected]> >> wrote: >>> >>> It's fine. You can synchronize with a static monitor the creation on the >>> injector per worker. That's how I do it. >>> >>> public class InjectorProvider { >>> >>> private static Injector injector; >>> >>> public static Injector get() { >>> if (injector == null) { >>> synchronized (InjectorProvider.class) { >>> if (injector == null) { >>> injector = Guice.createInjector( >>> new DAOModule(), >>> new S3Module(); >>> } >>> } >>> } >>> >>> return injector; >>> } >>> >>> >>> On Tue, Mar 25, 2014 at 6:24 PM, Adam Lewis <[email protected]> wrote: >>>> >>>> >>>>> Doesn't Storm 0.9 have a prepare for the worker? >>>> >>>> >>>> No, I don't think it does, but please point this out if I'm mistaken. I >>>> found the right JIRA issue though: >>>> https://issues.apache.org/jira/browse/STORM-126 >>>> >>>> Seems like the patch was well along but hasn't seen any recent activity. >>> >>> >> >
