Fix

apache · Mar 24, 2024 · f362987 · f362987
1 parent 9d98e11
commit f362987
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/KeyValueStorageRocksDB.java b/...server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/KeyValueStorageRocksDB.java
@@ -433,6 +433,7 @@ public void compact(byte[] firstKey, byte[] lastKey) throws IOException {
     public void compact() throws IOException {
         readLock.lock();
         try {
+            throwIfClosed();
             final long start = System.currentTimeMillis();
             final int oriRocksDBFileCount = db.getLiveFilesMetaData().size();
             final long oriRocksDBSize = getRocksDBSize();
@@ -646,9 +647,10 @@ public long count() throws IOException {
     }
 
     @Override
-    public Batch newBatch() {
+    public Batch newBatch() throws IOException {
         readLock.lock();
         try {
+            throwIfClosed();
             return new RocksDBBatch(writeBatchMaxSize);
         } finally {
             readLock.unlock();