[pulsar] branch master updated: [fix][broker] Fix thread-safety issue with currentLedgerEntries and currentLedgerSize fields (#17868)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new ef0f38515a7 [fix][broker] Fix thread-safety issue with 
currentLedgerEntries and currentLedgerSize fields (#17868)
ef0f38515a7 is described below

commit ef0f38515a707357d6bdd969e0c3a832a45ec235
Author: Lari Hotari <lhot...@users.noreply.github.com>
AuthorDate: Tue Dec 20 23:08:28 2022 +0200

    [fix][broker] Fix thread-safety issue with currentLedgerEntries and 
currentLedgerSize fields (#17868)
---
 .../java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java
 
b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java
index 616f05155db..c849a347c7d 100644
--- 
a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java
+++ 
b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java
@@ -216,8 +216,8 @@ public class ManagedLedgerImpl implements ManagedLedger, 
CreateCallback {
     private static final CompletableFuture<PositionImpl> NULL_OFFLOAD_PROMISE 
= CompletableFuture
             .completedFuture(PositionImpl.LATEST);
     protected volatile LedgerHandle currentLedger;
-    protected long currentLedgerEntries = 0;
-    protected long currentLedgerSize = 0;
+    protected volatile long currentLedgerEntries = 0;
+    protected volatile long currentLedgerSize = 0;
     protected volatile long lastLedgerCreatedTimestamp = 0;
     private volatile long lastLedgerCreationFailureTimestamp = 0;
     private long lastLedgerCreationInitiationTimestamp = 0;