Edward Zhang created EAGLE-116:
----------------------------------
Summary: StormTopologyCompiler's boltCache looks not working
Key: EAGLE-116
URL: https://issues.apache.org/jira/browse/EAGLE-116
Project: Eagle
Issue Type: Bug
Affects Versions: 0.3.0
Reporter: Edward Zhang
Priority: Minor
Fix For: 0.3.0
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)
