Why you need to use storm's config? Use it only for storm configuration, not for your topology.
On 24 January 2015 at 19:17, clay teahouse <[email protected]> wrote: > Thanks Irek. So you are passing the config through the bolt's constructor. > I was trying to use storm's config object to pass my own config around. > > On Sat, Jan 24, 2015 at 10:10 AM, Irek Khasyanov <[email protected]> wrote: > >> Well, I'm using this code: >> >> public EventsBatchBolt(TopologyConfig config, long emitFrequency, >> TimeUnit unit) { >> super(emitFrequency, unit); >> topologyConfig = config; >> } >> >> And where I submitting topology, I have: >> >> builder.setBolt("event_batch", new EventsBatchBolt(topologyConfig, 10, >> TimeUnit.SECONDS), 1) >> >> TopologyConfig is just generic class with my configuration >> >> On 24 January 2015 at 18:59, clay teahouse <[email protected]> >> wrote: >> >>> Any feedback on what the issue could be would be appreciated. >>> I am getting an instance of Config and add my static objects to it and >>> want to access these objects in bolt's prepare method. >>> Config config = new Config(); >>> config.put("objectname", objectinstance); >>> >>> StormSubmitter.submitTopology(topologyname, config, >>> builder.createTopology()); >>> >>> And in bolt's prepare method, I try to extract the object. >>> >>> prepare(Map stormConfig,TopologyContext context) { >>> >>> ObjectType obj = (objectType) stormConfig.get("objectname"); >>> >>> } >>> >>> Object type is either String or ArrayList or HashMap. >>> >>> >>> On Sat, Jan 24, 2015 at 12:01 AM, clay teahouse <[email protected]> >>> wrote: >>> >>>> Hi, >>>> >>>> I am trying to pass some objects to the bolts through config, but I am >>>> not having much success. These objects are hashmap and arrarylists. I am >>>> assuming these are serializable. Any idea what could be wrong? >>>> >>>> thanks, >>>> Clay >>>> >>>> >>> >> >> >> -- >> With best regards, Irek Khasyanov. >> > > -- With best regards, Irek Khasyanov.
