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

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

commit aa8017819053542e43b0f30448583a76f725d70d
Author: Rajan Dhabalia <rdhaba...@apache.org>
AuthorDate: Mon Mar 17 01:44:38 2025 -0700

    [fix][broker] Fix Metadata event synchronizer should not fail with bad 
version (#24080)
    
    (cherry picked from commit 781b1ff6467b56dab5fd8e41e051c768202f3fb6)
---
 .../java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
index 1c2ef4dad3c..ccbb2a11a90 100644
--- 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
+++ 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
@@ -155,7 +155,7 @@ public abstract class AbstractMetadataStore implements 
MetadataStoreExtended, Co
             }
             // else update the event
             CompletableFuture<?> updateResult = (event.getType() == 
NotificationType.Deleted)
-                    ? deleteInternal(event.getPath(), 
Optional.ofNullable(event.getExpectedVersion()))
+                    ? deleteInternal(event.getPath(), Optional.empty())
                     : putInternal(event.getPath(), event.getValue(),
                     Optional.ofNullable(event.getExpectedVersion()), options);
             updateResult.thenApply(stat -> {

Reply via email to