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/02 06:25:58 UTC

[bookkeeper] 05/22: reduce unnecessary checkpoints (#3341)

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 304873e807fbe7e81e048e9b1741154353f4ffa3
Author: LinChen <15...@qq.com>
AuthorDate: Mon Jun 20 15:01:47 2022 +0800

    reduce unnecessary checkpoints (#3341)
    
    (cherry picked from commit 6e268800c5d5d8f6c250202feed68fb38964251e)
---
 .../bookkeeper/bookie/storage/ldb/SingleDirectoryDbLedgerStorage.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/SingleDirectoryDbLedgerStorage.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/SingleDirectoryDbLedgerStorage.java
index 753b88f7ec..9df81bc83a 100644
--- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/SingleDirectoryDbLedgerStorage.java
+++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/SingleDirectoryDbLedgerStorage.java
@@ -706,6 +706,9 @@ public class SingleDirectoryDbLedgerStorage implements CompactableLedgerStorage
         // Only a single flush operation can happen at a time
         flushMutex.lock();
         try {
+            if (writeCache.isEmpty()) {
+                return;
+            }
             // Swap the write cache so that writes can continue to happen while the flush is
             // ongoing
             swapWriteCache();