From 2e200699bfcb510d6ad84f4ab6e7798c02fb587c Mon Sep 17 00:00:00 2001 From: Vasily Gerasimov Date: Wed, 5 Jun 2024 10:45:17 +0000 Subject: [PATCH] Fix sizeBytesToRequest in case if no request has been done --- topic/src/main/java/tech/ydb/topic/read/impl/ReaderImpl.java | 1 + 1 file changed, 1 insertion(+) diff --git a/topic/src/main/java/tech/ydb/topic/read/impl/ReaderImpl.java b/topic/src/main/java/tech/ydb/topic/read/impl/ReaderImpl.java index 58491839f..93c6834b9 100644 --- a/topic/src/main/java/tech/ydb/topic/read/impl/ReaderImpl.java +++ b/topic/src/main/java/tech/ydb/topic/read/impl/ReaderImpl.java @@ -259,6 +259,7 @@ private void sendReadRequest() { if (currentSizeBytesToRequest <= 0) { logger.debug("[{}] Nothing to request in DataRequest. sizeBytesToRequest == {}", fullId, currentSizeBytesToRequest); + sizeBytesToRequest.addAndGet(currentSizeBytesToRequest); return; } logger.debug("[{}] Sending DataRequest with {} bytes", fullId, currentSizeBytesToRequest);