You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by dc...@apache.org on 2021/07/02 18:32:52 UTC

[cassandra] branch cassandra-4.0 updated: BinLog does not close chronicle queue leaving this to GC to cleanup

This is an automated email from the ASF dual-hosted git repository.

dcapwell pushed a commit to branch cassandra-4.0
in repository https://gitbox.apache.org/repos/asf/cassandra.git


The following commit(s) were added to refs/heads/cassandra-4.0 by this push:
     new bb3a39a  BinLog does not close chronicle queue leaving this to GC to cleanup
bb3a39a is described below

commit bb3a39ad4db82bf10a17d775f558ee18a4a70198
Author: David Capwell <dc...@apache.org>
AuthorDate: Fri Jul 2 10:38:40 2021 -0700

    BinLog does not close chronicle queue leaving this to GC to cleanup
    
    patch by David Capwell; reviewed by Caleb Rackliffe, Marcus Eriksson for CASSANDRA-16774
---
 CHANGES.txt                                            | 1 +
 src/java/org/apache/cassandra/utils/binlog/BinLog.java | 2 ++
 2 files changed, 3 insertions(+)

diff --git a/CHANGES.txt b/CHANGES.txt
index aa95028..dbbb705 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
 4.0.1
+ * BinLog does not close chronicle queue leaving this to GC to cleanup (CASSANDRA-16774)
  * Add repaired/unrepaired bytes back to nodetool (CASSANDRA-15282)
  * Upgrade lz4-java to 1.8.0 to add RH6 support back (CASSANDRA-16753)
  * Improve DiagnosticEventService.publish(event) logging message of events (CASSANDRA-16749)
diff --git a/src/java/org/apache/cassandra/utils/binlog/BinLog.java b/src/java/org/apache/cassandra/utils/binlog/BinLog.java
index f622954..63f74a3 100644
--- a/src/java/org/apache/cassandra/utils/binlog/BinLog.java
+++ b/src/java/org/apache/cassandra/utils/binlog/BinLog.java
@@ -169,7 +169,9 @@ public class BinLog implements Runnable
         shouldContinue = false;
         sampleQueue.put(NO_OP);
         binLogThread.join();
+        appender.close();
         appender = null;
+        queue.close();
         queue = null;
         archiver.stop();
         currentPaths.remove(path);

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org