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();