commit c40c7ee9fb35eafea9c9923dfcf62706ea5d36bf
author Michael Marshall <mmarshall@apache.org> Sun Sep 18 06:27:59 2022 -0700
committer GitHub <noreply@github.com> Sun Sep 18 15:27:59 2022 +0200
tree 512c8e020ae8b42a91b96980027def82951746c0
parent 4ec1009b42c226d6f9b9eb52b03e50bb4cdbb3cd

[fix][metadata] Set revalidateAfterReconnection true for certain failures (#17664)

pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/ResourceLockImpl.java

diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/ResourceLockImpl.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/ResourceLockImpl.java
index bc3f47d..22eaccc 100644
--- a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/ResourceLockImpl.java
+++ b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/ResourceLockImpl.java
@@ -196,6 +196,7 @@
                             // We failed to revalidate the lock due to connectivity issue
                             // Continue assuming we hold the lock, until we can revalidate it, either
                             // on Reconnected or SessionReestablished events.
+                            revalidateAfterReconnection = true;
                             log.warn("Failed to revalidate the lock at {}. Retrying later on reconnection {}", path,
                                     ex.getCause().getMessage());
                         }