Reputation: 183
Which is the default garbage collector in Storm and why?
Can someone please explain what happens to tuples in memory after they are acknowledged by a Bolt?
Upvotes: 3
Views: 1012
Reputation: 20245
Since Apache Storm is a JVM based project, then when it comes to garbage collection, the garbage collection policy used by Storm JVM process will be used.
I might be wrong but it looks to me that you are mixing two things here, JVM GC and Storm Acknowledge process.
Here is how acknowledge in Apache Storm was created:
Apache Storm spouts keep the messages (events) in their output queues until they are being acknowledged. The acknowledgement occurs only after the successful processing of a message (event) by the topology. If an acknowledgement comes for a message (event) within a reasonable amount of time, then the spouts clear the message from their output queue. If an acknowledgement didn’t come within a predefined period (30 second default), then the spouts replay the message again through the topology.
Should be read: Guaranteeing Message Processing.
Upvotes: 0