From 1b24bb6d4f647a583273889d0c33ceb46ebfbd00 Mon Sep 17 00:00:00 2001
From: "liwen.2022" <liwen.2022@bytedance.com>
Date: Thu, 15 Jun 2023 18:23:50 +0800
Subject: [PATCH] fix: batch append should also checkQuotaAndWait

Change-Id: I608a1912120f124e15df75924ad2a14d8f523645
---
 .../io/openmessaging/storage/dledger/DLedgerEntryPusher.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/dledger/src/main/java/io/openmessaging/storage/dledger/DLedgerEntryPusher.java b/dledger/src/main/java/io/openmessaging/storage/dledger/DLedgerEntryPusher.java
index 86c03c05..3777554c 100644
--- 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();