Fix

apache · Feb 21, 2024 · 7e2631d · 7e2631d
1 parent e8b41ad
commit 7e2631d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java
@@ -679,8 +679,8 @@ public Journal(int journalIndex, File journalDirectory, ServerConfiguration conf
         this.journalWriteBufferSize = conf.getJournalWriteBufferSizeKB() * KB;
         this.syncData = conf.getJournalSyncData();
         this.maxBackupJournals = conf.getMaxBackupJournals();
-        this.forceWriteThread = new ForceWriteThread((__) -> this.interrupt(), conf.getJournalAdaptiveGroupWrites(),
-                journalStatsLogger);
+        this.forceWriteThread = new ForceWriteThread((__) -> this.interruptThread(),
+                conf.getJournalAdaptiveGroupWrites(), journalStatsLogger);
         this.maxGroupWaitInNanos = TimeUnit.MILLISECONDS.toNanos(conf.getJournalMaxGroupWaitMSec());
         this.bufferedWritesThreshold = conf.getJournalBufferedWritesThreshold();
         this.bufferedEntriesThreshold = conf.getJournalBufferedEntriesThreshold();
@@ -1289,7 +1289,7 @@ public void joinThread() throws InterruptedException {
         }
     }
 
-    public void interrupt() {
+    public void interruptThread() {
         if (thread != null) {
             thread.interrupt();
         }