You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bookkeeper.apache.org by yo...@apache.org on 2022/08/01 13:44:58 UTC
[bookkeeper] 12/17: Close journal channel in testJunkEndedJournal (#3307)
This is an automated email from the ASF dual-hosted git repository.
yong pushed a commit to branch branch-4.15
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
commit ee9a765fd71cf271940dd6273ffd7ef54c0d86b0
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)
---
.../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 7ddb9b0f26..e5a1d78d8c 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
@@ -539,6 +539,7 @@ public class BookieJournalTest {
JournalChannel jc = writeV2Journal(BookieImpl.getCurrentDirectory(journalDir), 0);
jc.getBufferedChannel().write(Unpooled.wrappedBuffer("JunkJunkJunk".getBytes()));
jc.getBufferedChannel().flushAndForceWrite(false);
+ jc.close();
writeIndexFileForLedger(ledgerDir, 1, "testPasswd".getBytes());