huginn created HBASE-30396:
------------------------------

             Summary: Release inflight buffer when replication source terminates
                 Key: HBASE-30396
                 URL: https://issues.apache.org/jira/browse/HBASE-30396
             Project: HBase
          Issue Type: Bug
          Components: Replication
            Reporter: huginn


When a replication source terminates while a WAL entry batch is in flight, its 
buffer quota can remain accounted indefinitely.

ReplicationSourceShipper.shipEdits polls a WALEntryBatch from the reader queue. 
The buffer quota is released after successful shipping through postShipEdits; 
if the worker stops before successful shipping, the batch is no longer in the 
reader queue and cleanup cannot release its quota.

Track whether the polled batch was released by successful shipping and release 
the batch quota after the shipping loop when it was not successfully shipped. 
Add a regression test for a stopped shipper holding an in-flight batch.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to