mimaison commented on code in PR #15705:
URL: https://github.com/apache/kafka/pull/15705#discussion_r1565719621
##########
clients/src/main/java/org/apache/kafka/common/memory/GarbageCollectedMemoryPool.java:
##########
@@ -37,13 +37,13 @@ public class GarbageCollectedMemoryPool extends
SimpleMemoryPool implements Auto
//serves 2 purposes - 1st it maintains the ref objects reachable (which is
a requirement for them
//to ever be enqueued), 2nd keeps some (small) metadata for every buffer
allocated
private final Map<BufferReference, BufferMetadata> buffersInFlight = new
ConcurrentHashMap<>();
- private final GarbageCollectionListener gcListener = new
GarbageCollectionListener();
private final Thread gcListenerThread;
- private volatile boolean alive = true;
+ private volatile boolean alive;
public GarbageCollectedMemoryPool(long sizeBytes, int
maxSingleAllocationSize, boolean strict, Sensor oomPeriodSensor) {
super(sizeBytes, maxSingleAllocationSize, strict, oomPeriodSensor);
this.alive = true;
Review Comment:
Yes I agree
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
