pá 21. 8. 2015 v 2:17 odesílatel Jason Chen <[email protected]> napsal:
> My processing RichBolt acks immediately (since I fail-fast if I run into > any parsing issues), so I can’t think of a reason why so many tuples would > be pending (8 million+ ?). > The BaseBasicBolt acks the tuples for you, not the BaseRichBolt. Your implementation does no acking at all, which causes your problems. Florian's solution is perfect.
