[ https://issues.apache.org/jira/browse/EAGLE-116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Edward Zhang updated EAGLE-116: ------------------------------- Affects Version/s: (was: 0.3.0) > StormTopologyCompiler's boltCache looks not working > --------------------------------------------------- > > Key: EAGLE-116 > URL: https://issues.apache.org/jira/browse/EAGLE-116 > Project: Eagle > Issue Type: Bug > Reporter: Edward Zhang > Assignee: Edward Zhang > Priority: Minor > > I saw boltCache is not used anymore, need investigate and clean that if > necessary. > val boltCache = scala.collection.mutable.Map[StreamProducer[Any], > StormBoltWrapper]() > def createBoltIfAbsent(graph: StreamProducerGraph, producer : > StreamProducer[Any]): BaseRichBolt ={ > boltCache.get(producer) match{ > case Some(bolt) => bolt > case None => { > StormBoltFactory.getBoltWrapper(graph, producer, config) > } > } > } -- This message was sent by Atlassian JIRA (v6.3.4#6332)