[fix] fix thread safety problem, ensure the visibility of changingEms…

…emble
apache · Jan 11, 2024 · 7cdab79 · 7cdab79
1 parent d8c1f1a
commit 7cdab79
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandle.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandle.java
@@ -165,7 +165,7 @@ private enum HandleState {
  public static final long INVALID_LEDGER_ID = -0xABCDABCDL;
 
  final Object metadataLock = new Object();
- boolean changingEnsemble = false;
+ volatile boolean changingEnsemble = false;
  final AtomicInteger numEnsembleChanges = new AtomicInteger(0);
  Queue<PendingAddOp> pendingAddOps;
  ExplicitLacFlushPolicy explicitLacFlushPolicy;