You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bookkeeper.apache.org by ni...@apache.org on 2022/09/19 10:00:20 UTC

[bookkeeper] 09/22: Close journal channel in testJunkEndedJournal (#3307)

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

nicoloboschi pushed a commit to branch ds-4.14
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git

commit eedc321b8426e592809c6869a023da6c3ff10a5e
Author: ZhangJian He <sh...@gmail.com>
AuthorDate: Mon Jun 6 13:41:47 2022 +0800

    Close journal channel in testJunkEndedJournal (#3307)
    
    (cherry picked from commit d3229c5cdb73c53de86d6e4b5a44a9eea9a5852d)
    (cherry picked from commit 7e4f1eeaa7909e47e7a2c5cc1fc7bfad87cf3b29)
---
 .../src/test/java/org/apache/bookkeeper/bookie/BookieJournalTest.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/BookieJournalTest.java b/bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/BookieJournalTest.java
index 88f2db73b8..04b2138031 100644
--- a/bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/BookieJournalTest.java
+++ b/bookkeeper-server/src/test/java/org/apache/bookkeeper/bookie/BookieJournalTest.java
@@ -537,6 +537,7 @@ public class BookieJournalTest {
         JournalChannel jc = writeV2Journal(Bookie.getCurrentDirectory(journalDir), 0);
         jc.getBufferedChannel().write(Unpooled.wrappedBuffer("JunkJunkJunk".getBytes()));
         jc.getBufferedChannel().flushAndForceWrite(false);
+        jc.close();
 
         writeIndexFileForLedger(ledgerDir, 1, "testPasswd".getBytes());