[ISSUE openmessaging#295] Batch append should also checkQuotaAndWait

Change-Id: I608a1912120f124e15df75924ad2a14d8f523645 Co-authored-by: liwen.2022 <[email protected]>
TheR1sing3un · Jun 25, 2023 · 5d600f7 · 5d600f7
1 parent 786c7c7
commit 5d600f7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/dledger/src/main/java/io/openmessaging/storage/dledger/DLedgerEntryPusher.java b/dledger/src/main/java/io/openmessaging/storage/dledger/DLedgerEntryPusher.java
@@ -586,6 +586,7 @@ private void doBatchAppendInner(long index) throws Exception {
             if (null == entry) {
                 return;
             }
+            checkQuotaAndWait(entry);
             batchAppendEntryRequest.addEntry(entry);
             if (batchAppendEntryRequest.getTotalSize() >= dLedgerConfig.getMaxBatchPushSize()) {
                 sendBatchAppendEntryRequest();