Fix typo

apache · Dec 23, 2022 · 4369fc3 · 4369fc3
1 parent d670439
commit 4369fc3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/RocksdbMetadataStore.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/RocksdbMetadataStore.java
@@ -349,7 +349,7 @@ public synchronized void close() throws MetadataStoreException {
         }
 
         instancesCache.remove(this.metadataUrl, this);
-        if (isClosed.compareAndExchange(false, true)) {
+        if (isClosed.compareAndSet(false, true)) {
             try {
                 dbStateLock.writeLock().lock();
                 log.info("close.instanceId={}", instanceId);