You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2025/06/02 08:03:16 UTC
(pulsar) 04/12: [fix][offload] Complete the future outside of the reading loop in BlobStoreBackedReadHandleImplV2.readAsync (#24331)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit ecf61642458dfc9694ed56b796496528b12a4a05
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Thu May 22 13:06:23 2025 +0300
[fix][offload] Complete the future outside of the reading loop in BlobStoreBackedReadHandleImplV2.readAsync (#24331)
(cherry picked from commit bdf6277456db9df1618adcd07b588f3a94714796)
---
.../mledger/offload/jcloud/impl/BlobStoreBackedReadHandleImplV2.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBackedReadHandleImplV2.java b/tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBackedReadHandleImplV2.java
index 502f475174c..3fffd18a5d8 100644
--- a/tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBackedReadHandleImplV2.java
+++ b/tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBackedReadHandleImplV2.java
@@ -233,8 +233,8 @@ public class BlobStoreBackedReadHandleImplV2 implements ReadHandle {
entries.forEach(LedgerEntry::close);
}
- promise.complete(LedgerEntriesImpl.create(entries));
}
+ promise.complete(LedgerEntriesImpl.create(entries));
});
return promise;
}