Gangrui Li created STORM-289:
--------------------------------
Summary: Trident DRPC memory leak
Key: STORM-289
URL: https://issues.apache.org/jira/browse/STORM-289
Project: Apache Storm (Incubating)
Issue Type: Bug
Affects Versions: 0.9.2-incubating
Reporter: Gangrui Li
storm.trident.spout.RichSpoutBatchTriggerer.java
Missing code "_msgIdToBatchId.put(r, batchIdVal);" in emit method.
As a consequence, ack/fail will get null batchId for each DRPC invoking, which
makes _finishConditions map larger and larger until out of memory.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
